disruptionlistener

package
v0.0.0-...-03450b5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 19, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Unless explicitly stated otherwise all files in this repository are licensed under the Apache License Version 2.0. This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2025 Datadog, Inc.

Unless explicitly stated otherwise all files in this repository are licensed under the Apache License Version 2.0. This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2025 Datadog, Inc.

Unless explicitly stated otherwise all files in this repository are licensed under the Apache License Version 2.0. This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2025 Datadog, Inc.

Index

Constants

This section is empty.

Variables

View Source 
var DisruptionListener_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "disruptionlistener.DisruptionListener",
	HandlerType: (*DisruptionListenerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Disrupt",
			Handler:    _DisruptionListener_Disrupt_Handler,
		},
		{
			MethodName: "ResetDisruptions",
			Handler:    _DisruptionListener_ResetDisruptions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "disruptionlistener.proto",
}

DisruptionListener_ServiceDesc is the grpc.ServiceDesc for DisruptionListener service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_disruptionlistener_proto protoreflect.FileDescriptor

Functions

func RegisterDisruptionListenerServer 

func RegisterDisruptionListenerServer(s grpc.ServiceRegistrar, srv DisruptionListenerServer)

Types

type AlterationSpec 

type AlterationSpec struct {
	ErrorToReturn    string `protobuf:"bytes,1,opt,name=errorToReturn,proto3" json:"errorToReturn,omitempty"`
	OverrideToReturn string `protobuf:"bytes,2,opt,name=overrideToReturn,proto3" json:"overrideToReturn,omitempty"`
	QueryPercent     int32  `protobuf:"varint,3,opt,name=queryPercent,proto3" json:"queryPercent,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterationSpec) Descriptor deprecated 

func (*AlterationSpec) Descriptor() ([]byte, []int)

Deprecated: Use AlterationSpec.ProtoReflect.Descriptor instead.

func (*AlterationSpec) GetErrorToReturn 

func (x *AlterationSpec) GetErrorToReturn() string

func (*AlterationSpec) GetOverrideToReturn 

func (x *AlterationSpec) GetOverrideToReturn() string

func (*AlterationSpec) GetQueryPercent 

func (x *AlterationSpec) GetQueryPercent() int32

func (*AlterationSpec) ProtoMessage 

func (*AlterationSpec) ProtoMessage()

func (*AlterationSpec) ProtoReflect 

func (x *AlterationSpec) ProtoReflect() protoreflect.Message

func (*AlterationSpec) Reset 

func (x *AlterationSpec) Reset()

func (*AlterationSpec) String 

func (x *AlterationSpec) String() string

type DisruptionListenerClient 

type DisruptionListenerClient interface {
	Disrupt(ctx context.Context, in *DisruptionSpec, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ResetDisruptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DisruptionListenerClient is the client API for DisruptionListener service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDisruptionListenerClient 

func NewDisruptionListenerClient(cc grpc.ClientConnInterface) DisruptionListenerClient

type DisruptionListenerClientMock 

type DisruptionListenerClientMock struct {
	mock.Mock
}

DisruptionListenerClientMock is an autogenerated mock type for the DisruptionListenerClient type

func NewDisruptionListenerClientMock 

func NewDisruptionListenerClientMock(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisruptionListenerClientMock

NewDisruptionListenerClientMock creates a new instance of DisruptionListenerClientMock. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisruptionListenerClientMock) Disrupt 

func (_m *DisruptionListenerClientMock) Disrupt(ctx context.Context, in *DisruptionSpec, opts ...grpc.CallOption) (*emptypb.Empty, error)

Disrupt provides a mock function with given fields: ctx, in, opts

func (*DisruptionListenerClientMock) EXPECT 

func (_m *DisruptionListenerClientMock) EXPECT() *DisruptionListenerClientMock_Expecter

func (*DisruptionListenerClientMock) ResetDisruptions 

func (_m *DisruptionListenerClientMock) ResetDisruptions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)

ResetDisruptions provides a mock function with given fields: ctx, in, opts

type DisruptionListenerClientMock_Disrupt_Call 

type DisruptionListenerClientMock_Disrupt_Call struct {
	*mock.Call
}

DisruptionListenerClientMock_Disrupt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disrupt'

func (*DisruptionListenerClientMock_Disrupt_Call) Return 

func (_c *DisruptionListenerClientMock_Disrupt_Call) Return(_a0 *emptypb.Empty, _a1 error) *DisruptionListenerClientMock_Disrupt_Call

func (*DisruptionListenerClientMock_Disrupt_Call) Run 

func (_c *DisruptionListenerClientMock_Disrupt_Call) Run(run func(ctx context.Context, in *DisruptionSpec, opts ...grpc.CallOption)) *DisruptionListenerClientMock_Disrupt_Call

func (*DisruptionListenerClientMock_Disrupt_Call) RunAndReturn 

func (_c *DisruptionListenerClientMock_Disrupt_Call) RunAndReturn(run func(context.Context, *DisruptionSpec, ...grpc.CallOption) (*emptypb.Empty, error)) *DisruptionListenerClientMock_Disrupt_Call

type DisruptionListenerClientMock_Expecter 

type DisruptionListenerClientMock_Expecter struct {
	// contains filtered or unexported fields
}

func (*DisruptionListenerClientMock_Expecter) Disrupt 

func (_e *DisruptionListenerClientMock_Expecter) Disrupt(ctx interface{}, in interface{}, opts ...interface{}) *DisruptionListenerClientMock_Disrupt_Call

Disrupt is a helper method to define mock.On call

  • ctx context.Context
  • in *DisruptionSpec
  • opts ...grpc.CallOption

func (*DisruptionListenerClientMock_Expecter) ResetDisruptions 

func (_e *DisruptionListenerClientMock_Expecter) ResetDisruptions(ctx interface{}, in interface{}, opts ...interface{}) *DisruptionListenerClientMock_ResetDisruptions_Call

ResetDisruptions is a helper method to define mock.On call

  • ctx context.Context
  • in *emptypb.Empty
  • opts ...grpc.CallOption

type DisruptionListenerClientMock_ResetDisruptions_Call 

type DisruptionListenerClientMock_ResetDisruptions_Call struct {
	*mock.Call
}

DisruptionListenerClientMock_ResetDisruptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResetDisruptions'

func (*DisruptionListenerClientMock_ResetDisruptions_Call) Return 

func (_c *DisruptionListenerClientMock_ResetDisruptions_Call) Return(_a0 *emptypb.Empty, _a1 error) *DisruptionListenerClientMock_ResetDisruptions_Call

func (*DisruptionListenerClientMock_ResetDisruptions_Call) Run 

func (_c *DisruptionListenerClientMock_ResetDisruptions_Call) Run(run func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption)) *DisruptionListenerClientMock_ResetDisruptions_Call

func (*DisruptionListenerClientMock_ResetDisruptions_Call) RunAndReturn 

func (_c *DisruptionListenerClientMock_ResetDisruptions_Call) RunAndReturn(run func(context.Context, *emptypb.Empty, ...grpc.CallOption) (*emptypb.Empty, error)) *DisruptionListenerClientMock_ResetDisruptions_Call

type DisruptionListenerServer 

type DisruptionListenerServer interface {
	Disrupt(context.Context, *DisruptionSpec) (*emptypb.Empty, error)
	ResetDisruptions(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DisruptionListenerServer is the server API for DisruptionListener service. All implementations must embed UnimplementedDisruptionListenerServer for forward compatibility

type DisruptionListenerServerMock 

type DisruptionListenerServerMock struct {
	mock.Mock
}

DisruptionListenerServerMock is an autogenerated mock type for the DisruptionListenerServer type

func NewDisruptionListenerServerMock 

func NewDisruptionListenerServerMock(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisruptionListenerServerMock

NewDisruptionListenerServerMock creates a new instance of DisruptionListenerServerMock. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisruptionListenerServerMock) Disrupt 

func (_m *DisruptionListenerServerMock) Disrupt(_a0 context.Context, _a1 *DisruptionSpec) (*emptypb.Empty, error)

Disrupt provides a mock function with given fields: _a0, _a1

func (*DisruptionListenerServerMock) EXPECT 

func (_m *DisruptionListenerServerMock) EXPECT() *DisruptionListenerServerMock_Expecter

func (*DisruptionListenerServerMock) ResetDisruptions 

func (_m *DisruptionListenerServerMock) ResetDisruptions(_a0 context.Context, _a1 *emptypb.Empty) (*emptypb.Empty, error)

ResetDisruptions provides a mock function with given fields: _a0, _a1

type DisruptionListenerServerMock_Disrupt_Call 

type DisruptionListenerServerMock_Disrupt_Call struct {
	*mock.Call
}

DisruptionListenerServerMock_Disrupt_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Disrupt'

func (*DisruptionListenerServerMock_Disrupt_Call) Return 

func (_c *DisruptionListenerServerMock_Disrupt_Call) Return(_a0 *emptypb.Empty, _a1 error) *DisruptionListenerServerMock_Disrupt_Call

func (*DisruptionListenerServerMock_Disrupt_Call) Run 

func (_c *DisruptionListenerServerMock_Disrupt_Call) Run(run func(_a0 context.Context, _a1 *DisruptionSpec)) *DisruptionListenerServerMock_Disrupt_Call

func (*DisruptionListenerServerMock_Disrupt_Call) RunAndReturn 

func (_c *DisruptionListenerServerMock_Disrupt_Call) RunAndReturn(run func(context.Context, *DisruptionSpec) (*emptypb.Empty, error)) *DisruptionListenerServerMock_Disrupt_Call

type DisruptionListenerServerMock_Expecter 

type DisruptionListenerServerMock_Expecter struct {
	// contains filtered or unexported fields
}

func (*DisruptionListenerServerMock_Expecter) Disrupt 

func (_e *DisruptionListenerServerMock_Expecter) Disrupt(_a0 interface{}, _a1 interface{}) *DisruptionListenerServerMock_Disrupt_Call

Disrupt is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *DisruptionSpec

func (*DisruptionListenerServerMock_Expecter) ResetDisruptions 

func (_e *DisruptionListenerServerMock_Expecter) ResetDisruptions(_a0 interface{}, _a1 interface{}) *DisruptionListenerServerMock_ResetDisruptions_Call

ResetDisruptions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *emptypb.Empty

type DisruptionListenerServerMock_ResetDisruptions_Call 

type DisruptionListenerServerMock_ResetDisruptions_Call struct {
	*mock.Call
}

DisruptionListenerServerMock_ResetDisruptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ResetDisruptions'

func (*DisruptionListenerServerMock_ResetDisruptions_Call) Return 

func (_c *DisruptionListenerServerMock_ResetDisruptions_Call) Return(_a0 *emptypb.Empty, _a1 error) *DisruptionListenerServerMock_ResetDisruptions_Call

func (*DisruptionListenerServerMock_ResetDisruptions_Call) Run 

func (_c *DisruptionListenerServerMock_ResetDisruptions_Call) Run(run func(_a0 context.Context, _a1 *emptypb.Empty)) *DisruptionListenerServerMock_ResetDisruptions_Call

func (*DisruptionListenerServerMock_ResetDisruptions_Call) RunAndReturn 

func (_c *DisruptionListenerServerMock_ResetDisruptions_Call) RunAndReturn(run func(context.Context, *emptypb.Empty) (*emptypb.Empty, error)) *DisruptionListenerServerMock_ResetDisruptions_Call

type DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call 

type DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call struct {
	*mock.Call
}

DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mustEmbedUnimplementedDisruptionListenerServer'

func (*DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Return 

func (_c *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Return() *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

func (*DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Run 

func (_c *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Run(run func()) *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

func (*DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) RunAndReturn 

func (_c *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) RunAndReturn(run func()) *DisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

type DisruptionSpec 

type DisruptionSpec struct {
	Endpoints []*EndpointSpec `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

func (*DisruptionSpec) Descriptor deprecated 

func (*DisruptionSpec) Descriptor() ([]byte, []int)

Deprecated: Use DisruptionSpec.ProtoReflect.Descriptor instead.

func (*DisruptionSpec) GetEndpoints 

func (x *DisruptionSpec) GetEndpoints() []*EndpointSpec

func (*DisruptionSpec) ProtoMessage 

func (*DisruptionSpec) ProtoMessage()

func (*DisruptionSpec) ProtoReflect 

func (x *DisruptionSpec) ProtoReflect() protoreflect.Message

func (*DisruptionSpec) Reset 

func (x *DisruptionSpec) Reset()

func (*DisruptionSpec) String 

func (x *DisruptionSpec) String() string

type EndpointSpec 

type EndpointSpec struct {
	TargetEndpoint string            `protobuf:"bytes,1,opt,name=targetEndpoint,proto3" json:"targetEndpoint,omitempty"`
	Alterations    []*AlterationSpec `protobuf:"bytes,2,rep,name=alterations,proto3" json:"alterations,omitempty"`
	// contains filtered or unexported fields
}

func (*EndpointSpec) Descriptor deprecated 

func (*EndpointSpec) Descriptor() ([]byte, []int)

Deprecated: Use EndpointSpec.ProtoReflect.Descriptor instead.

func (*EndpointSpec) GetAlterations 

func (x *EndpointSpec) GetAlterations() []*AlterationSpec

func (*EndpointSpec) GetTargetEndpoint 

func (x *EndpointSpec) GetTargetEndpoint() string

func (*EndpointSpec) ProtoMessage 

func (*EndpointSpec) ProtoMessage()

func (*EndpointSpec) ProtoReflect 

func (x *EndpointSpec) ProtoReflect() protoreflect.Message

func (*EndpointSpec) Reset 

func (x *EndpointSpec) Reset()

func (*EndpointSpec) String 

func (x *EndpointSpec) String() string

type UnimplementedDisruptionListenerServer 

type UnimplementedDisruptionListenerServer struct {
}

UnimplementedDisruptionListenerServer must be embedded to have forward compatible implementations.

func (UnimplementedDisruptionListenerServer) Disrupt 

func (UnimplementedDisruptionListenerServer) Disrupt(context.Context, *DisruptionSpec) (*emptypb.Empty, error)

func (UnimplementedDisruptionListenerServer) ResetDisruptions 

func (UnimplementedDisruptionListenerServer) ResetDisruptions(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

type UnsafeDisruptionListenerServer 

type UnsafeDisruptionListenerServer interface {
	// contains filtered or unexported methods
}

UnsafeDisruptionListenerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DisruptionListenerServer will result in compilation errors.

type UnsafeDisruptionListenerServerMock 

type UnsafeDisruptionListenerServerMock struct {
	mock.Mock
}

UnsafeDisruptionListenerServerMock is an autogenerated mock type for the UnsafeDisruptionListenerServer type

func NewUnsafeDisruptionListenerServerMock 

func NewUnsafeDisruptionListenerServerMock(t interface {
	mock.TestingT
	Cleanup(func())
}) *UnsafeDisruptionListenerServerMock

NewUnsafeDisruptionListenerServerMock creates a new instance of UnsafeDisruptionListenerServerMock. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UnsafeDisruptionListenerServerMock) EXPECT 

func (_m *UnsafeDisruptionListenerServerMock) EXPECT() *UnsafeDisruptionListenerServerMock_Expecter

type UnsafeDisruptionListenerServerMock_Expecter 

type UnsafeDisruptionListenerServerMock_Expecter struct {
	// contains filtered or unexported fields
}

type UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call 

type UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call struct {
	*mock.Call
}

UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'mustEmbedUnimplementedDisruptionListenerServer'

func (*UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Return 

func (_c *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Return() *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

func (*UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Run 

func (_c *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) Run(run func()) *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

func (*UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) RunAndReturn 

func (_c *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call) RunAndReturn(run func()) *UnsafeDisruptionListenerServerMock_mustEmbedUnimplementedDisruptionListenerServer_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.