(t *testing.T)
| 31 | ) |
| 32 | |
| 33 | func TestAMQPOutput(t *testing.T) { |
| 34 | c := NewWithOpts(WithRun()) |
| 35 | |
| 36 | err := c.flags.Parse([]string{"--config-file=_fixtures/output.yml"}) |
| 37 | require.NoError(t, c.viper.BindPFlags(c.flags)) |
| 38 | require.NoError(t, err) |
| 39 | require.NoError(t, c.TryLoadFile(c.GetConfigFile())) |
| 40 | |
| 41 | require.NoError(t, c.Init()) |
| 42 | |
| 43 | require.NotNil(t, c.Output) |
| 44 | require.IsType(t, amqp.Config{}, c.Output.Output) |
| 45 | |
| 46 | amqpConfig := c.Output.Output.(amqp.Config) |
| 47 | assert.Equal(t, "amqp://localhost:5672", amqpConfig.URL) |
| 48 | assert.Equal(t, time.Second*5, amqpConfig.Timeout) |
| 49 | assert.Equal(t, "fibratus", amqpConfig.Exchange) |
| 50 | assert.Equal(t, "topic", amqpConfig.ExchangeType) |
| 51 | assert.Equal(t, "fibratus", amqpConfig.RoutingKey) |
| 52 | assert.Equal(t, "/", amqpConfig.Vhost) |
| 53 | } |
| 54 | |
| 55 | func TestHTTPOutput(t *testing.T) { |
| 56 | c := NewWithOpts(WithRun()) |
nothing calls this directly
no test coverage detected