Documentation ¶
Index ¶
- Variables
- func RegisterRelayServer(s grpc.ServiceRegistrar, srv RelayServer)
- type ConfigRequest
- func (*ConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigRequest) GetBatchInterval() int32
- func (x *ConfigRequest) GetBatchSize() int32
- func (x *ConfigRequest) GetListenerType() []ListenerType
- func (*ConfigRequest) ProtoMessage()
- func (x *ConfigRequest) ProtoReflect() protoreflect.Message
- func (x *ConfigRequest) Reset()
- func (x *ConfigRequest) String() string
- type ConfigResponse
- func (*ConfigResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigResponse) GetIdentifer() string
- func (x *ConfigResponse) GetSuccess() bool
- func (*ConfigResponse) ProtoMessage()
- func (x *ConfigResponse) ProtoReflect() protoreflect.Message
- func (x *ConfigResponse) Reset()
- func (x *ConfigResponse) String() string
- type Listener
- type ListenerType
- func (ListenerType) Descriptor() protoreflect.EnumDescriptor
- func (x ListenerType) Enum() *ListenerType
- func (ListenerType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListenerType) Number() protoreflect.EnumNumber
- func (x ListenerType) String() string
- func (ListenerType) Type() protoreflect.EnumType
- type RelayClient
- type RelayServer
- type StartRequest
- type StartResponse
- type StatusRequest
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetCurrentSize() int32
- func (x *StatusResponse) GetFailed() int32
- func (x *StatusResponse) GetLastSent() *timestamppb.Timestamp
- func (x *StatusResponse) GetListenerType() []*Listener
- func (x *StatusResponse) GetProcessed() int32
- func (x *StatusResponse) GetRunning() bool
- func (x *StatusResponse) GetStartedAt() *timestamppb.Timestamp
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type StopRequest
- type StopResponse
- type UnimplementedRelayServer
- func (UnimplementedRelayServer) Config(context.Context, *ConfigRequest) (*ConfigResponse, error)
- func (UnimplementedRelayServer) Start(context.Context, *StartRequest) (*StartResponse, error)
- func (UnimplementedRelayServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- func (UnimplementedRelayServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
- type UnsafeRelayServer
Constants ¶
This section is empty.
Variables ¶
var ( ListenerType_name = map[int32]string{ 0: "LISTENER_TYPE_UNSPECIFIED", 1: "LISTENER_TYPE_HTTP", 2: "LISTENER_TYPE_WEBSOCKET", 3: "LISTENER_TYPE_SNS", 4: "LISTENER_TYPE_SQS", 5: "LISTENER_TYPE_KINESIS", 6: "LISTENER_TYPE_KAFKA", 7: "LISTENER_TYPE_UDP", } ListenerType_value = map[string]int32{ "LISTENER_TYPE_UNSPECIFIED": 0, "LISTENER_TYPE_HTTP": 1, "LISTENER_TYPE_WEBSOCKET": 2, "LISTENER_TYPE_SNS": 3, "LISTENER_TYPE_SQS": 4, "LISTENER_TYPE_KINESIS": 5, "LISTENER_TYPE_KAFKA": 6, "LISTENER_TYPE_UDP": 7, } )
Enum value maps for ListenerType.
var File_relay_config_v1_config_proto protoreflect.FileDescriptor
var Relay_ServiceDesc = grpc.ServiceDesc{ ServiceName: "relay.config.v1.Relay", HandlerType: (*RelayServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _Relay_Start_Handler, }, { MethodName: "Stop", Handler: _Relay_Stop_Handler, }, { MethodName: "Config", Handler: _Relay_Config_Handler, }, { MethodName: "Status", Handler: _Relay_Status_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "relay/config/v1/config.proto", }
Relay_ServiceDesc is the grpc.ServiceDesc for Relay service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRelayServer ¶
func RegisterRelayServer(s grpc.ServiceRegistrar, srv RelayServer)
Types ¶
type ConfigRequest ¶
type ConfigRequest struct { BatchInterval int32 `protobuf:"varint,1,opt,name=batchInterval,proto3" json:"batchInterval,omitempty"` BatchSize int32 `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"` // Ability to disable listener type ListenerType []ListenerType `protobuf:"varint,3,rep,packed,name=listenerType,proto3,enum=relay.config.v1.ListenerType" json:"listenerType,omitempty"` // contains filtered or unexported fields }
func (*ConfigRequest) Descriptor
deprecated
func (*ConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.
func (*ConfigRequest) GetBatchInterval ¶
func (x *ConfigRequest) GetBatchInterval() int32
func (*ConfigRequest) GetBatchSize ¶
func (x *ConfigRequest) GetBatchSize() int32
func (*ConfigRequest) GetListenerType ¶
func (x *ConfigRequest) GetListenerType() []ListenerType
func (*ConfigRequest) ProtoMessage ¶
func (*ConfigRequest) ProtoMessage()
func (*ConfigRequest) ProtoReflect ¶
func (x *ConfigRequest) ProtoReflect() protoreflect.Message
func (*ConfigRequest) Reset ¶
func (x *ConfigRequest) Reset()
func (*ConfigRequest) String ¶
func (x *ConfigRequest) String() string
type ConfigResponse ¶
type ConfigResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Identifer string `protobuf:"bytes,2,opt,name=identifer,proto3" json:"identifer,omitempty"` // contains filtered or unexported fields }
func (*ConfigResponse) Descriptor
deprecated
func (*ConfigResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConfigResponse.ProtoReflect.Descriptor instead.
func (*ConfigResponse) GetIdentifer ¶
func (x *ConfigResponse) GetIdentifer() string
func (*ConfigResponse) GetSuccess ¶
func (x *ConfigResponse) GetSuccess() bool
func (*ConfigResponse) ProtoMessage ¶
func (*ConfigResponse) ProtoMessage()
func (*ConfigResponse) ProtoReflect ¶
func (x *ConfigResponse) ProtoReflect() protoreflect.Message
func (*ConfigResponse) Reset ¶
func (x *ConfigResponse) Reset()
func (*ConfigResponse) String ¶
func (x *ConfigResponse) String() string
type Listener ¶
type Listener struct { ListenerType ListenerType `protobuf:"varint,1,opt,name=listenerType,proto3,enum=relay.config.v1.ListenerType" json:"listenerType,omitempty"` Active bool `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"` // contains filtered or unexported fields }
func (*Listener) Descriptor
deprecated
func (*Listener) GetListenerType ¶
func (x *Listener) GetListenerType() ListenerType
func (*Listener) ProtoMessage ¶
func (*Listener) ProtoMessage()
func (*Listener) ProtoReflect ¶
func (x *Listener) ProtoReflect() protoreflect.Message
type ListenerType ¶
type ListenerType int32
const ( ListenerType_LISTENER_TYPE_UNSPECIFIED ListenerType = 0 ListenerType_LISTENER_TYPE_HTTP ListenerType = 1 ListenerType_LISTENER_TYPE_WEBSOCKET ListenerType = 2 ListenerType_LISTENER_TYPE_SNS ListenerType = 3 ListenerType_LISTENER_TYPE_SQS ListenerType = 4 ListenerType_LISTENER_TYPE_KINESIS ListenerType = 5 ListenerType_LISTENER_TYPE_KAFKA ListenerType = 6 ListenerType_LISTENER_TYPE_UDP ListenerType = 7 )
func (ListenerType) Descriptor ¶
func (ListenerType) Descriptor() protoreflect.EnumDescriptor
func (ListenerType) Enum ¶
func (x ListenerType) Enum() *ListenerType
func (ListenerType) EnumDescriptor
deprecated
func (ListenerType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ListenerType.Descriptor instead.
func (ListenerType) Number ¶
func (x ListenerType) Number() protoreflect.EnumNumber
func (ListenerType) String ¶
func (x ListenerType) String() string
func (ListenerType) Type ¶
func (ListenerType) Type() protoreflect.EnumType
type RelayClient ¶
type RelayClient interface { Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error) Config(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*ConfigResponse, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) }
RelayClient is the client API for Relay 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 NewRelayClient ¶
func NewRelayClient(cc grpc.ClientConnInterface) RelayClient
type RelayServer ¶
type RelayServer interface { Start(context.Context, *StartRequest) (*StartResponse, error) Stop(context.Context, *StopRequest) (*StopResponse, error) Config(context.Context, *ConfigRequest) (*ConfigResponse, error) Status(context.Context, *StatusRequest) (*StatusResponse, error) // contains filtered or unexported methods }
RelayServer is the server API for Relay service. All implementations must embed UnimplementedRelayServer for forward compatibility
type StartRequest ¶
type StartRequest struct { Config *ConfigRequest `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*StartRequest) Descriptor
deprecated
func (*StartRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.
func (*StartRequest) GetConfig ¶
func (x *StartRequest) GetConfig() *ConfigRequest
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) ProtoReflect ¶
func (x *StartRequest) ProtoReflect() protoreflect.Message
func (*StartRequest) Reset ¶
func (x *StartRequest) Reset()
func (*StartRequest) String ¶
func (x *StartRequest) String() string
type StartResponse ¶
type StartResponse struct { Status *StatusResponse `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*StartResponse) Descriptor
deprecated
func (*StartResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.
func (*StartResponse) GetStatus ¶
func (x *StartResponse) GetStatus() *StatusResponse
func (*StartResponse) ProtoMessage ¶
func (*StartResponse) ProtoMessage()
func (*StartResponse) ProtoReflect ¶
func (x *StartResponse) ProtoReflect() protoreflect.Message
func (*StartResponse) Reset ¶
func (x *StartResponse) Reset()
func (*StartResponse) String ¶
func (x *StartResponse) String() string
type StatusRequest ¶
type StatusRequest struct {
// contains filtered or unexported fields
}
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct { Processed int32 `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"` CurrentSize int32 `protobuf:"varint,2,opt,name=currentSize,proto3" json:"currentSize,omitempty"` Failed int32 `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"` ListenerType []*Listener `protobuf:"bytes,4,rep,name=listenerType,proto3" json:"listenerType,omitempty"` Running bool `protobuf:"varint,9,opt,name=running,proto3" json:"running,omitempty"` LastSent *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=lastSent,proto3" json:"lastSent,omitempty"` StartedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=startedAt,proto3" json:"startedAt,omitempty"` // contains filtered or unexported fields }
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetCurrentSize ¶
func (x *StatusResponse) GetCurrentSize() int32
func (*StatusResponse) GetFailed ¶
func (x *StatusResponse) GetFailed() int32
func (*StatusResponse) GetLastSent ¶
func (x *StatusResponse) GetLastSent() *timestamppb.Timestamp
func (*StatusResponse) GetListenerType ¶
func (x *StatusResponse) GetListenerType() []*Listener
func (*StatusResponse) GetProcessed ¶
func (x *StatusResponse) GetProcessed() int32
func (*StatusResponse) GetRunning ¶
func (x *StatusResponse) GetRunning() bool
func (*StatusResponse) GetStartedAt ¶
func (x *StatusResponse) GetStartedAt() *timestamppb.Timestamp
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type StopRequest ¶
type StopRequest struct {
// contains filtered or unexported fields
}
func (*StopRequest) Descriptor
deprecated
func (*StopRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) ProtoReflect ¶
func (x *StopRequest) ProtoReflect() protoreflect.Message
func (*StopRequest) Reset ¶
func (x *StopRequest) Reset()
func (*StopRequest) String ¶
func (x *StopRequest) String() string
type StopResponse ¶
type StopResponse struct { Status *StatusResponse `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*StopResponse) Descriptor
deprecated
func (*StopResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.
func (*StopResponse) GetStatus ¶
func (x *StopResponse) GetStatus() *StatusResponse
func (*StopResponse) ProtoMessage ¶
func (*StopResponse) ProtoMessage()
func (*StopResponse) ProtoReflect ¶
func (x *StopResponse) ProtoReflect() protoreflect.Message
func (*StopResponse) Reset ¶
func (x *StopResponse) Reset()
func (*StopResponse) String ¶
func (x *StopResponse) String() string
type UnimplementedRelayServer ¶
type UnimplementedRelayServer struct { }
UnimplementedRelayServer must be embedded to have forward compatible implementations.
func (UnimplementedRelayServer) Config ¶
func (UnimplementedRelayServer) Config(context.Context, *ConfigRequest) (*ConfigResponse, error)
func (UnimplementedRelayServer) Start ¶
func (UnimplementedRelayServer) Start(context.Context, *StartRequest) (*StartResponse, error)
func (UnimplementedRelayServer) Status ¶
func (UnimplementedRelayServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
func (UnimplementedRelayServer) Stop ¶
func (UnimplementedRelayServer) Stop(context.Context, *StopRequest) (*StopResponse, error)
type UnsafeRelayServer ¶
type UnsafeRelayServer interface {
// contains filtered or unexported methods
}
UnsafeRelayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RelayServer will result in compilation errors.