trigger

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package trigger is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var File_trigger_proto protoreflect.FileDescriptor
View Source 
var TriggerWorker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.trigger.TriggerWorker",
	HandlerType: (*TriggerWorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _TriggerWorker_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _TriggerWorker_Stop_Handler,
		},
		{
			MethodName: "AddSubscription",
			Handler:    _TriggerWorker_AddSubscription_Handler,
		},
		{
			MethodName: "RemoveSubscription",
			Handler:    _TriggerWorker_RemoveSubscription_Handler,
		},
		{
			MethodName: "PauseSubscription",
			Handler:    _TriggerWorker_PauseSubscription_Handler,
		},
		{
			MethodName: "ResumeSubscription",
			Handler:    _TriggerWorker_ResumeSubscription_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "trigger.proto",
}

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

Functions

func RegisterTriggerWorkerServer 

func RegisterTriggerWorkerServer(s grpc.ServiceRegistrar, srv TriggerWorkerServer)

Types

type AddSubscriptionRequest 

type AddSubscriptionRequest struct {
	Id                   uint64                   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Config               *meta.SubscriptionConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	Filters              []*meta.Filter           `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
	Sink                 string                   `protobuf:"bytes,4,opt,name=sink,proto3" json:"sink,omitempty"`
	SinkCredential       *meta.SinkCredential     `protobuf:"bytes,5,opt,name=sink_credential,json=sinkCredential,proto3" json:"sink_credential,omitempty"`
	Protocol             meta.Protocol            `protobuf:"varint,6,opt,name=protocol,proto3,enum=vanus.core.meta.Protocol" json:"protocol,omitempty"`
	ProtocolSettings     *meta.ProtocolSetting    `protobuf:"bytes,7,opt,name=protocol_settings,json=protocolSettings,proto3" json:"protocol_settings,omitempty"`
	Transformer          *meta.Transformer        `protobuf:"bytes,9,opt,name=transformer,proto3" json:"transformer,omitempty"`
	Offsets              []*meta.OffsetInfo       `protobuf:"bytes,10,rep,name=offsets,proto3" json:"offsets,omitempty"`
	EventbusId           uint64                   `protobuf:"varint,11,opt,name=eventbus_id,json=eventbusId,proto3" json:"eventbus_id,omitempty"`
	DeadLetterEventbusId uint64                   `` /* 127-byte string literal not displayed */
	RetryEventbusId      uint64                   `protobuf:"varint,13,opt,name=retry_eventbus_id,json=retryEventbusId,proto3" json:"retry_eventbus_id,omitempty"`
	TimerEventbusId      uint64                   `protobuf:"varint,14,opt,name=timer_eventbus_id,json=timerEventbusId,proto3" json:"timer_eventbus_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use AddSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*AddSubscriptionRequest) GetConfig 

func (x *AddSubscriptionRequest) GetConfig() *meta.SubscriptionConfig

func (*AddSubscriptionRequest) GetDeadLetterEventbusId 

func (x *AddSubscriptionRequest) GetDeadLetterEventbusId() uint64

func (*AddSubscriptionRequest) GetEventbusId 

func (x *AddSubscriptionRequest) GetEventbusId() uint64

func (*AddSubscriptionRequest) GetFilters 

func (x *AddSubscriptionRequest) GetFilters() []*meta.Filter

func (*AddSubscriptionRequest) GetId 

func (x *AddSubscriptionRequest) GetId() uint64

func (*AddSubscriptionRequest) GetOffsets 

func (x *AddSubscriptionRequest) GetOffsets() []*meta.OffsetInfo

func (*AddSubscriptionRequest) GetProtocol 

func (x *AddSubscriptionRequest) GetProtocol() meta.Protocol

func (*AddSubscriptionRequest) GetProtocolSettings 

func (x *AddSubscriptionRequest) GetProtocolSettings() *meta.ProtocolSetting

func (*AddSubscriptionRequest) GetRetryEventbusId 

func (x *AddSubscriptionRequest) GetRetryEventbusId() uint64

func (*AddSubscriptionRequest) GetSink 

func (x *AddSubscriptionRequest) GetSink() string

func (*AddSubscriptionRequest) GetSinkCredential 

func (x *AddSubscriptionRequest) GetSinkCredential() *meta.SinkCredential

func (*AddSubscriptionRequest) GetTimerEventbusId 

func (x *AddSubscriptionRequest) GetTimerEventbusId() uint64

func (*AddSubscriptionRequest) GetTransformer 

func (x *AddSubscriptionRequest) GetTransformer() *meta.Transformer

func (*AddSubscriptionRequest) ProtoMessage 

func (*AddSubscriptionRequest) ProtoMessage()

func (*AddSubscriptionRequest) ProtoReflect 

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

func (*AddSubscriptionRequest) Reset 

func (x *AddSubscriptionRequest) Reset()

func (*AddSubscriptionRequest) String 

func (x *AddSubscriptionRequest) String() string

type AddSubscriptionResponse 

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

func (*AddSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use AddSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*AddSubscriptionResponse) ProtoMessage 

func (*AddSubscriptionResponse) ProtoMessage()

func (*AddSubscriptionResponse) ProtoReflect 

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

func (*AddSubscriptionResponse) Reset 

func (x *AddSubscriptionResponse) Reset()

func (*AddSubscriptionResponse) String 

func (x *AddSubscriptionResponse) String() string

type MockTriggerWorkerClient 

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

MockTriggerWorkerClient is a mock of TriggerWorkerClient interface.

func NewMockTriggerWorkerClient 

func NewMockTriggerWorkerClient(ctrl *gomock.Controller) *MockTriggerWorkerClient

NewMockTriggerWorkerClient creates a new mock instance.

func (*MockTriggerWorkerClient) AddSubscription 

func (m *MockTriggerWorkerClient) AddSubscription(ctx context.Context, in *AddSubscriptionRequest, opts ...grpc.CallOption) (*AddSubscriptionResponse, error)

AddSubscription mocks base method.

func (*MockTriggerWorkerClient) EXPECT 

func (m *MockTriggerWorkerClient) EXPECT() *MockTriggerWorkerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerWorkerClient) PauseSubscription 

func (m *MockTriggerWorkerClient) PauseSubscription(ctx context.Context, in *PauseSubscriptionRequest, opts ...grpc.CallOption) (*PauseSubscriptionResponse, error)

PauseSubscription mocks base method.

func (*MockTriggerWorkerClient) RemoveSubscription 

func (m *MockTriggerWorkerClient) RemoveSubscription(ctx context.Context, in *RemoveSubscriptionRequest, opts ...grpc.CallOption) (*RemoveSubscriptionResponse, error)

RemoveSubscription mocks base method.

func (*MockTriggerWorkerClient) ResumeSubscription 

func (m *MockTriggerWorkerClient) ResumeSubscription(ctx context.Context, in *ResumeSubscriptionRequest, opts ...grpc.CallOption) (*ResumeSubscriptionResponse, error)

ResumeSubscription mocks base method.

func (*MockTriggerWorkerClient) Start 

func (m *MockTriggerWorkerClient) Start(ctx context.Context, in *StartTriggerWorkerRequest, opts ...grpc.CallOption) (*StartTriggerWorkerResponse, error)

Start mocks base method.

func (*MockTriggerWorkerClient) Stop 

func (m *MockTriggerWorkerClient) Stop(ctx context.Context, in *StopTriggerWorkerRequest, opts ...grpc.CallOption) (*StopTriggerWorkerResponse, error)

Stop mocks base method.

type MockTriggerWorkerClientMockRecorder 

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

MockTriggerWorkerClientMockRecorder is the mock recorder for MockTriggerWorkerClient.

func (*MockTriggerWorkerClientMockRecorder) AddSubscription 

func (mr *MockTriggerWorkerClientMockRecorder) AddSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

AddSubscription indicates an expected call of AddSubscription.

func (*MockTriggerWorkerClientMockRecorder) PauseSubscription 

func (mr *MockTriggerWorkerClientMockRecorder) PauseSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

PauseSubscription indicates an expected call of PauseSubscription.

func (*MockTriggerWorkerClientMockRecorder) RemoveSubscription 

func (mr *MockTriggerWorkerClientMockRecorder) RemoveSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveSubscription indicates an expected call of RemoveSubscription.

func (*MockTriggerWorkerClientMockRecorder) ResumeSubscription 

func (mr *MockTriggerWorkerClientMockRecorder) ResumeSubscription(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockTriggerWorkerClientMockRecorder) Start 

func (mr *MockTriggerWorkerClientMockRecorder) Start(ctx, in interface{}, opts ...interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockTriggerWorkerClientMockRecorder) Stop 

func (mr *MockTriggerWorkerClientMockRecorder) Stop(ctx, in interface{}, opts ...interface{}) *gomock.Call

Stop indicates an expected call of Stop.

type MockTriggerWorkerServer 

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

MockTriggerWorkerServer is a mock of TriggerWorkerServer interface.

func NewMockTriggerWorkerServer 

func NewMockTriggerWorkerServer(ctrl *gomock.Controller) *MockTriggerWorkerServer

NewMockTriggerWorkerServer creates a new mock instance.

func (*MockTriggerWorkerServer) AddSubscription 

func (m *MockTriggerWorkerServer) AddSubscription(arg0 context.Context, arg1 *AddSubscriptionRequest) (*AddSubscriptionResponse, error)

AddSubscription mocks base method.

func (*MockTriggerWorkerServer) EXPECT 

func (m *MockTriggerWorkerServer) EXPECT() *MockTriggerWorkerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTriggerWorkerServer) PauseSubscription 

func (m *MockTriggerWorkerServer) PauseSubscription(arg0 context.Context, arg1 *PauseSubscriptionRequest) (*PauseSubscriptionResponse, error)

PauseSubscription mocks base method.

func (*MockTriggerWorkerServer) RemoveSubscription 

func (m *MockTriggerWorkerServer) RemoveSubscription(arg0 context.Context, arg1 *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)

RemoveSubscription mocks base method.

func (*MockTriggerWorkerServer) ResumeSubscription 

func (m *MockTriggerWorkerServer) ResumeSubscription(arg0 context.Context, arg1 *ResumeSubscriptionRequest) (*ResumeSubscriptionResponse, error)

ResumeSubscription mocks base method.

func (*MockTriggerWorkerServer) Start 

func (m *MockTriggerWorkerServer) Start(arg0 context.Context, arg1 *StartTriggerWorkerRequest) (*StartTriggerWorkerResponse, error)

Start mocks base method.

func (*MockTriggerWorkerServer) Stop 

func (m *MockTriggerWorkerServer) Stop(arg0 context.Context, arg1 *StopTriggerWorkerRequest) (*StopTriggerWorkerResponse, error)

Stop mocks base method.

type MockTriggerWorkerServerMockRecorder 

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

MockTriggerWorkerServerMockRecorder is the mock recorder for MockTriggerWorkerServer.

func (*MockTriggerWorkerServerMockRecorder) AddSubscription 

func (mr *MockTriggerWorkerServerMockRecorder) AddSubscription(arg0, arg1 interface{}) *gomock.Call

AddSubscription indicates an expected call of AddSubscription.

func (*MockTriggerWorkerServerMockRecorder) PauseSubscription 

func (mr *MockTriggerWorkerServerMockRecorder) PauseSubscription(arg0, arg1 interface{}) *gomock.Call

PauseSubscription indicates an expected call of PauseSubscription.

func (*MockTriggerWorkerServerMockRecorder) RemoveSubscription 

func (mr *MockTriggerWorkerServerMockRecorder) RemoveSubscription(arg0, arg1 interface{}) *gomock.Call

RemoveSubscription indicates an expected call of RemoveSubscription.

func (*MockTriggerWorkerServerMockRecorder) ResumeSubscription 

func (mr *MockTriggerWorkerServerMockRecorder) ResumeSubscription(arg0, arg1 interface{}) *gomock.Call

ResumeSubscription indicates an expected call of ResumeSubscription.

func (*MockTriggerWorkerServerMockRecorder) Start 

func (mr *MockTriggerWorkerServerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockTriggerWorkerServerMockRecorder) Stop 

func (mr *MockTriggerWorkerServerMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

type MockUnsafeTriggerWorkerServer 

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

MockUnsafeTriggerWorkerServer is a mock of UnsafeTriggerWorkerServer interface.

func NewMockUnsafeTriggerWorkerServer 

func NewMockUnsafeTriggerWorkerServer(ctrl *gomock.Controller) *MockUnsafeTriggerWorkerServer

NewMockUnsafeTriggerWorkerServer creates a new mock instance.

func (*MockUnsafeTriggerWorkerServer) EXPECT 

func (m *MockUnsafeTriggerWorkerServer) EXPECT() *MockUnsafeTriggerWorkerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeTriggerWorkerServerMockRecorder 

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

MockUnsafeTriggerWorkerServerMockRecorder is the mock recorder for MockUnsafeTriggerWorkerServer.

type PauseSubscriptionRequest 

type PauseSubscriptionRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PauseSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use PauseSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*PauseSubscriptionRequest) GetSubscriptionId 

func (x *PauseSubscriptionRequest) GetSubscriptionId() uint64

func (*PauseSubscriptionRequest) ProtoMessage 

func (*PauseSubscriptionRequest) ProtoMessage()

func (*PauseSubscriptionRequest) ProtoReflect 

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

func (*PauseSubscriptionRequest) Reset 

func (x *PauseSubscriptionRequest) Reset()

func (*PauseSubscriptionRequest) String 

func (x *PauseSubscriptionRequest) String() string

type PauseSubscriptionResponse 

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

func (*PauseSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use PauseSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*PauseSubscriptionResponse) ProtoMessage 

func (*PauseSubscriptionResponse) ProtoMessage()

func (*PauseSubscriptionResponse) ProtoReflect 

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

func (*PauseSubscriptionResponse) Reset 

func (x *PauseSubscriptionResponse) Reset()

func (*PauseSubscriptionResponse) String 

func (x *PauseSubscriptionResponse) String() string

type RemoveSubscriptionRequest 

type RemoveSubscriptionRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use RemoveSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*RemoveSubscriptionRequest) GetSubscriptionId 

func (x *RemoveSubscriptionRequest) GetSubscriptionId() uint64

func (*RemoveSubscriptionRequest) ProtoMessage 

func (*RemoveSubscriptionRequest) ProtoMessage()

func (*RemoveSubscriptionRequest) ProtoReflect 

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

func (*RemoveSubscriptionRequest) Reset 

func (x *RemoveSubscriptionRequest) Reset()

func (*RemoveSubscriptionRequest) String 

func (x *RemoveSubscriptionRequest) String() string

type RemoveSubscriptionResponse 

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

func (*RemoveSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use RemoveSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*RemoveSubscriptionResponse) ProtoMessage 

func (*RemoveSubscriptionResponse) ProtoMessage()

func (*RemoveSubscriptionResponse) ProtoReflect 

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

func (*RemoveSubscriptionResponse) Reset 

func (x *RemoveSubscriptionResponse) Reset()

func (*RemoveSubscriptionResponse) String 

func (x *RemoveSubscriptionResponse) String() string

type ResumeSubscriptionRequest 

type ResumeSubscriptionRequest struct {
	SubscriptionId uint64 `protobuf:"varint,1,opt,name=subscription_id,json=subscriptionId,proto3" json:"subscription_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeSubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use ResumeSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ResumeSubscriptionRequest) GetSubscriptionId 

func (x *ResumeSubscriptionRequest) GetSubscriptionId() uint64

func (*ResumeSubscriptionRequest) ProtoMessage 

func (*ResumeSubscriptionRequest) ProtoMessage()

func (*ResumeSubscriptionRequest) ProtoReflect 

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

func (*ResumeSubscriptionRequest) Reset 

func (x *ResumeSubscriptionRequest) Reset()

func (*ResumeSubscriptionRequest) String 

func (x *ResumeSubscriptionRequest) String() string

type ResumeSubscriptionResponse 

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

func (*ResumeSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use ResumeSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*ResumeSubscriptionResponse) ProtoMessage 

func (*ResumeSubscriptionResponse) ProtoMessage()

func (*ResumeSubscriptionResponse) ProtoReflect 

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

func (*ResumeSubscriptionResponse) Reset 

func (x *ResumeSubscriptionResponse) Reset()

func (*ResumeSubscriptionResponse) String 

func (x *ResumeSubscriptionResponse) String() string

type StartTriggerWorkerRequest 

type StartTriggerWorkerRequest struct {
	Config *config.ServerConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTriggerWorkerRequest) Descriptor deprecated 

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

Deprecated: Use StartTriggerWorkerRequest.ProtoReflect.Descriptor instead.

func (*StartTriggerWorkerRequest) GetConfig 

func (x *StartTriggerWorkerRequest) GetConfig() *config.ServerConfig

func (*StartTriggerWorkerRequest) ProtoMessage 

func (*StartTriggerWorkerRequest) ProtoMessage()

func (*StartTriggerWorkerRequest) ProtoReflect 

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

func (*StartTriggerWorkerRequest) Reset 

func (x *StartTriggerWorkerRequest) Reset()

func (*StartTriggerWorkerRequest) String 

func (x *StartTriggerWorkerRequest) String() string

type StartTriggerWorkerResponse 

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

func (*StartTriggerWorkerResponse) Descriptor deprecated 

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

Deprecated: Use StartTriggerWorkerResponse.ProtoReflect.Descriptor instead.

func (*StartTriggerWorkerResponse) ProtoMessage 

func (*StartTriggerWorkerResponse) ProtoMessage()

func (*StartTriggerWorkerResponse) ProtoReflect 

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

func (*StartTriggerWorkerResponse) Reset 

func (x *StartTriggerWorkerResponse) Reset()

func (*StartTriggerWorkerResponse) String 

func (x *StartTriggerWorkerResponse) String() string

type StopTriggerWorkerRequest 

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

func (*StopTriggerWorkerRequest) Descriptor deprecated 

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

Deprecated: Use StopTriggerWorkerRequest.ProtoReflect.Descriptor instead.

func (*StopTriggerWorkerRequest) ProtoMessage 

func (*StopTriggerWorkerRequest) ProtoMessage()

func (*StopTriggerWorkerRequest) ProtoReflect 

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

func (*StopTriggerWorkerRequest) Reset 

func (x *StopTriggerWorkerRequest) Reset()

func (*StopTriggerWorkerRequest) String 

func (x *StopTriggerWorkerRequest) String() string

type StopTriggerWorkerResponse 

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

func (*StopTriggerWorkerResponse) Descriptor deprecated 

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

Deprecated: Use StopTriggerWorkerResponse.ProtoReflect.Descriptor instead.

func (*StopTriggerWorkerResponse) ProtoMessage 

func (*StopTriggerWorkerResponse) ProtoMessage()

func (*StopTriggerWorkerResponse) ProtoReflect 

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

func (*StopTriggerWorkerResponse) Reset 

func (x *StopTriggerWorkerResponse) Reset()

func (*StopTriggerWorkerResponse) String 

func (x *StopTriggerWorkerResponse) String() string

type TriggerWorkerClient 

type TriggerWorkerClient interface {
	Start(ctx context.Context, in *StartTriggerWorkerRequest, opts ...grpc.CallOption) (*StartTriggerWorkerResponse, error)
	Stop(ctx context.Context, in *StopTriggerWorkerRequest, opts ...grpc.CallOption) (*StopTriggerWorkerResponse, error)
	AddSubscription(ctx context.Context, in *AddSubscriptionRequest, opts ...grpc.CallOption) (*AddSubscriptionResponse, error)
	RemoveSubscription(ctx context.Context, in *RemoveSubscriptionRequest, opts ...grpc.CallOption) (*RemoveSubscriptionResponse, error)
	PauseSubscription(ctx context.Context, in *PauseSubscriptionRequest, opts ...grpc.CallOption) (*PauseSubscriptionResponse, error)
	ResumeSubscription(ctx context.Context, in *ResumeSubscriptionRequest, opts ...grpc.CallOption) (*ResumeSubscriptionResponse, error)
}

TriggerWorkerClient is the client API for TriggerWorker 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 NewTriggerWorkerClient 

func NewTriggerWorkerClient(cc grpc.ClientConnInterface) TriggerWorkerClient

type TriggerWorkerServer 

type TriggerWorkerServer interface {
	Start(context.Context, *StartTriggerWorkerRequest) (*StartTriggerWorkerResponse, error)
	Stop(context.Context, *StopTriggerWorkerRequest) (*StopTriggerWorkerResponse, error)
	AddSubscription(context.Context, *AddSubscriptionRequest) (*AddSubscriptionResponse, error)
	RemoveSubscription(context.Context, *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)
	PauseSubscription(context.Context, *PauseSubscriptionRequest) (*PauseSubscriptionResponse, error)
	ResumeSubscription(context.Context, *ResumeSubscriptionRequest) (*ResumeSubscriptionResponse, error)
}

TriggerWorkerServer is the server API for TriggerWorker service. All implementations should embed UnimplementedTriggerWorkerServer for forward compatibility

type UnimplementedTriggerWorkerServer 

type UnimplementedTriggerWorkerServer struct {
}

UnimplementedTriggerWorkerServer should be embedded to have forward compatible implementations.

func (UnimplementedTriggerWorkerServer) AddSubscription 

func (UnimplementedTriggerWorkerServer) AddSubscription(context.Context, *AddSubscriptionRequest) (*AddSubscriptionResponse, error)

func (UnimplementedTriggerWorkerServer) PauseSubscription 

func (UnimplementedTriggerWorkerServer) PauseSubscription(context.Context, *PauseSubscriptionRequest) (*PauseSubscriptionResponse, error)

func (UnimplementedTriggerWorkerServer) RemoveSubscription 

func (UnimplementedTriggerWorkerServer) RemoveSubscription(context.Context, *RemoveSubscriptionRequest) (*RemoveSubscriptionResponse, error)

func (UnimplementedTriggerWorkerServer) ResumeSubscription 

func (UnimplementedTriggerWorkerServer) ResumeSubscription(context.Context, *ResumeSubscriptionRequest) (*ResumeSubscriptionResponse, error)

func (UnimplementedTriggerWorkerServer) Start 

func (UnimplementedTriggerWorkerServer) Start(context.Context, *StartTriggerWorkerRequest) (*StartTriggerWorkerResponse, error)

func (UnimplementedTriggerWorkerServer) Stop 

func (UnimplementedTriggerWorkerServer) Stop(context.Context, *StopTriggerWorkerRequest) (*StopTriggerWorkerResponse, error)

type UnsafeTriggerWorkerServer 

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

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

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.