v1

package
v0.0.0-...-12a582f Latest Latest
Warning

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

Go to latest
Published: May 17, 2024 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
var File_relay_config_v1_config_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Listener.ProtoReflect.Descriptor instead.

func (*Listener) GetActive

func (x *Listener) GetActive() bool

func (*Listener) GetListenerType

func (x *Listener) GetListenerType() ListenerType

func (*Listener) ProtoMessage

func (*Listener) ProtoMessage()

func (*Listener) ProtoReflect

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

func (*Listener) Reset

func (x *Listener) Reset()

func (*Listener) String

func (x *Listener) String() string

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) Enum

func (x ListenerType) Enum() *ListenerType

func (ListenerType) EnumDescriptor deprecated

func (ListenerType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListenerType.Descriptor instead.

func (ListenerType) Number

func (ListenerType) String

func (x ListenerType) String() string

func (ListenerType) Type

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) Start

func (UnimplementedRelayServer) Status

func (UnimplementedRelayServer) Stop

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL