本文整理汇总了Golang中github.com/elastic/beats/libbeat/outputs/mode/modetest.Signals函数的典型用法代码示例。如果您正苦于以下问题:Golang Signals函数的具体用法?Golang Signals怎么用?Golang Signals使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Signals函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: testSingleSendFlakyGuaranteed
func testSingleSendFlakyGuaranteed(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
CBPublish: modetest.PublishCollectAfterFailStart(25, &collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testGuaranteed, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:13,代码来源:single_test.go
示例2: testSingleSendFlakyFail
func testSingleSendFlakyFail(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
CBPublish: modetest.PublishCollectAfterFailStart(3, &collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:13,代码来源:single_test.go
示例3: testLoadBalancerFlakyGuaranteed
func testLoadBalancerFlakyGuaranteed(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
mode, _ := NewSync(
modetest.SyncClients(2, &modetest.MockClient{
Connected: true,
CBPublish: modetest.PublishCollectAfterFailStart(25, &collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testGuaranteed, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:14,代码来源:lbsync_test.go
示例4: testSingleSendOneEvent
func testSingleSendOneEvent(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
Connected: true,
CBPublish: modetest.PublishCollect(&collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:14,代码来源:single_test.go
示例5: testLoadBalancerOKSend
func testLoadBalancerOKSend(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
mode, _ := NewSync(
modetest.SyncClients(1, &modetest.MockClient{
Connected: false,
CBPublish: modetest.PublishCollect(&collected),
}),
2,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:14,代码来源:lbsync_test.go
示例6: testLoadBalancerFlakyConnectionOkSend
func testLoadBalancerFlakyConnectionOkSend(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
mode, _ := NewSync(
modetest.SyncClients(2, &modetest.MockClient{
Connected: true,
CBPublish: modetest.PublishCollectAfterFailStart(1, &collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:14,代码来源:lbsync_test.go
示例7: testAsyncLBFailSendWithoutActiveConnection
func testAsyncLBFailSendWithoutActiveConnection(t *testing.T, events []modetest.EventInfo) {
enableLogging([]string{"*"})
errFail := errors.New("fail connect")
mode, _ := NewAsync(
modetest.AsyncClients(2, &modetest.MockClient{
CBConnect: modetest.ConnectFail(errFail),
}),
2,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), nil)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:15,代码来源:lbasync_test.go
示例8: testAsyncLBTemporayFailure
func testAsyncLBTemporayFailure(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
mode, _ := NewAsync(
modetest.AsyncClients(1, &modetest.MockClient{
Connected: true,
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStartWith(
1, mode.ErrTempBulkFailure, &collected),
}),
3,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:15,代码来源:lbasync_test.go
示例9: testAsyncLBOKSend
func testAsyncLBOKSend(t *testing.T, events []modetest.EventInfo) {
enableLogging([]string{"*"})
var collected [][]common.MapStr
mode, _ := NewAsync(
modetest.AsyncClients(1, &modetest.MockClient{
CBAsyncPublish: modetest.AsyncPublishCollect(&collected),
}),
2,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:15,代码来源:lbasync_test.go
示例10: testAsyncLBFlakyConnectionOkSend
func testAsyncLBFlakyConnectionOkSend(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
tmpl := &modetest.MockClient{
Connected: true,
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStart(1, &collected),
}
mode, _ := NewAsync(
modetest.AsyncClients(2, tmpl),
3,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:15,代码来源:lbasync_test.go
示例11: testLoadBalancerTempFlakyInfAttempts
func testLoadBalancerTempFlakyInfAttempts(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
err := mode.ErrTempBulkFailure
mode, _ := NewSync(
modetest.SyncClients(2, &modetest.MockClient{
Connected: true,
CBPublish: modetest.PublishCollectAfterFailStartWith(25, err, &collected),
}),
0,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:15,代码来源:lbsync_test.go
示例12: testSingleSendFlakyInfAttempts
func testSingleSendFlakyInfAttempts(t *testing.T, events []modetest.EventInfo) {
enableLogging([]string{"*"})
var collected [][]outputs.Data
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
CBPublish: modetest.PublishCollectAfterFailStart(25, &collected),
}),
0, // infinite number of send attempts
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:15,代码来源:single_test.go
示例13: testLoadBalancerTempFlakyGuaranteed
func testLoadBalancerTempFlakyGuaranteed(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
err := mode.ErrTempBulkFailure
mode, _ := NewSync(
modetest.SyncClients(2, &modetest.MockClient{
Connected: true,
CBPublish: modetest.PublishCollectAfterFailStartWith(25, err, &collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testGuaranteed, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:15,代码来源:lbsync_test.go
示例14: testSingleConnectionFail
func testSingleConnectionFail(t *testing.T, events []modetest.EventInfo) {
var collected [][]outputs.Data
errFail := errors.New("fail connect")
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
Connected: false,
CBConnect: modetest.ConnectFail(errFail),
CBPublish: modetest.PublishCollect(&collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:16,代码来源:single_test.go
示例15: testSingleConnectFailConnectAndSend
func testSingleConnectFailConnectAndSend(t *testing.T, events []modetest.EventInfo) {
var collected [][]common.MapStr
errFail := errors.New("fail connect")
mode, _ := New(
modetest.NewMockClient(&modetest.MockClient{
Connected: false,
CBConnect: modetest.ConnectFailN(2, errFail),
CBPublish: modetest.PublishCollect(&collected),
}),
3,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:16,代码来源:single_test.go
示例16: testAsyncLBTempFlakyFail
func testAsyncLBTempFlakyFail(t *testing.T, events []modetest.EventInfo) {
enableLogging([]string{"*"})
var collected [][]outputs.Data
mode, _ := NewAsync(
modetest.AsyncClients(2, &modetest.MockClient{
Connected: true,
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStartWith(
6, mode.ErrTempBulkFailure, &collected),
}),
3,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:17,代码来源:lbasync_test.go
示例17: testLoadBalancerFailSendWithoutActiveConnections
func testLoadBalancerFailSendWithoutActiveConnections(
t *testing.T,
events []modetest.EventInfo,
) {
errFail := errors.New("fail connect")
mode, _ := NewSync(
modetest.SyncClients(2, &modetest.MockClient{
Connected: false,
CBConnect: modetest.ConnectFail(errFail),
}),
2,
1*time.Millisecond,
1*time.Millisecond,
10*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), nil)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:17,代码来源:lbsync_test.go
示例18: testAsyncLBFlakyFail
func testAsyncLBFlakyFail(t *testing.T, events []modetest.EventInfo) {
enableLogging([]string{"*"})
var collected [][]common.MapStr
err := errors.New("flaky")
mode, _ := NewAsync(
modetest.AsyncClients(2, &modetest.MockClient{
Connected: true,
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStartWith(3, err, &collected),
}),
3,
100*time.Millisecond,
100*time.Millisecond,
1*time.Second,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(false), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:17,代码来源:lbasync_test.go
示例19: testAsyncLBFlakyInfAttempts2
func testAsyncLBFlakyInfAttempts2(t *testing.T, events []modetest.EventInfo) {
if testing.Verbose() {
logp.LogInit(logp.LOG_DEBUG, "", false, true, []string{"*"})
}
var collected [][]common.MapStr
err := errors.New("flaky")
mode, _ := NewAsync(
modetest.AsyncClients(2, &modetest.MockClient{
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStartWith(
50, err, &collected),
}),
0,
1*time.Nanosecond,
1*time.Millisecond,
4*time.Millisecond,
)
modetest.TestMode(t, mode, testNoOpts, events, modetest.Signals(true), &collected)
}
开发者ID:ChongFeng,项目名称:beats,代码行数:19,代码来源:lbasync_test.go
示例20: testAsyncLBFlakyGuaranteed2
func testAsyncLBFlakyGuaranteed2(t *testing.T, events []modetest.EventInfo) {
if testing.Verbose() {
logp.LogInit(logp.LOG_DEBUG, "", false, true, []string{"*"})
}
var collected [][]outputs.Data
err := errors.New("flaky")
tmpl := &modetest.MockClient{
Connected: true,
CBAsyncPublish: modetest.AsyncPublishCollectAfterFailStartWith(50, err, &collected),
}
mode, _ := NewAsync(
modetest.AsyncClients(2, tmpl),
3,
1*time.Nanosecond,
1*time.Millisecond,
4*time.Millisecond,
)
modetest.TestMode(t, mode, testGuaranteed, events, modetest.Signals(true), &collected)
}
开发者ID:YaSuenag,项目名称:hsbeat,代码行数:20,代码来源:lbasync_test.go
注:本文中的github.com/elastic/beats/libbeat/outputs/mode/modetest.Signals函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论