proto

package
v0.0.0-...-6cff7d0 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2024 License: LGPL-3.0 Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Offset_name = map[int32]string{
		0: "OFFSET_DEFAULT",
		1: "OFFSET_NEWEST",
		2: "OFFSET_OLDEST",
	}
	Offset_value = map[string]int32{
		"OFFSET_DEFAULT": 0,
		"OFFSET_NEWEST":  1,
		"OFFSET_OLDEST":  2,
	}
)

Enum value maps for Offset.

View Source 
var File_proximo_proto protoreflect.FileDescriptor
View Source 
var MessageSink_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proximo.MessageSink",
	HandlerType: (*MessageSinkServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Publish",
			Handler:       _MessageSink_Publish_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proximo.proto",
}

MessageSink_ServiceDesc is the grpc.ServiceDesc for MessageSink 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 MessageSource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proximo.MessageSource",
	HandlerType: (*MessageSourceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Consume",
			Handler:       _MessageSource_Consume_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proximo.proto",
}

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

Functions

func RegisterMessageSinkServer 

func RegisterMessageSinkServer(s grpc.ServiceRegistrar, srv MessageSinkServer)

func RegisterMessageSourceServer 

func RegisterMessageSourceServer(s grpc.ServiceRegistrar, srv MessageSourceServer)

Types

type Confirmation 

type Confirmation struct {
	MsgID string `protobuf:"bytes,1,opt,name=msgID,proto3" json:"msgID,omitempty"`
	// contains filtered or unexported fields
}

func (*Confirmation) Descriptor deprecated 

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

Deprecated: Use Confirmation.ProtoReflect.Descriptor instead.

func (*Confirmation) GetMsgID 

func (x *Confirmation) GetMsgID() string

func (*Confirmation) ProtoMessage 

func (*Confirmation) ProtoMessage()

func (*Confirmation) ProtoReflect 

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

func (*Confirmation) Reset 

func (x *Confirmation) Reset()

func (*Confirmation) String 

func (x *Confirmation) String() string

type ConsumerRequest 

type ConsumerRequest struct {

	// expected if this is a start request
	StartRequest *StartConsumeRequest `protobuf:"bytes,2,opt,name=startRequest,proto3" json:"startRequest,omitempty"`
	// expected if this is a confirmation
	Confirmation *Confirmation `protobuf:"bytes,3,opt,name=confirmation,proto3" json:"confirmation,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumerRequest) Descriptor deprecated 

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

Deprecated: Use ConsumerRequest.ProtoReflect.Descriptor instead.

func (*ConsumerRequest) GetConfirmation 

func (x *ConsumerRequest) GetConfirmation() *Confirmation

func (*ConsumerRequest) GetStartRequest 

func (x *ConsumerRequest) GetStartRequest() *StartConsumeRequest

func (*ConsumerRequest) ProtoMessage 

func (*ConsumerRequest) ProtoMessage()

func (*ConsumerRequest) ProtoReflect 

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

func (*ConsumerRequest) Reset 

func (x *ConsumerRequest) Reset()

func (*ConsumerRequest) String 

func (x *ConsumerRequest) String() string

type Message 

type Message struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Key  []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData 

func (x *Message) GetData() []byte

func (*Message) GetId 

func (x *Message) GetId() string

func (*Message) GetKey 

func (x *Message) GetKey() []byte

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type MessageSinkClient 

type MessageSinkClient interface {
	Publish(ctx context.Context, opts ...grpc.CallOption) (MessageSink_PublishClient, error)
}

MessageSinkClient is the client API for MessageSink 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 NewMessageSinkClient 

func NewMessageSinkClient(cc grpc.ClientConnInterface) MessageSinkClient

type MessageSinkServer 

type MessageSinkServer interface {
	Publish(MessageSink_PublishServer) error
}

MessageSinkServer is the server API for MessageSink service. All implementations should embed UnimplementedMessageSinkServer for forward compatibility

type MessageSink_PublishClient 

type MessageSink_PublishClient interface {
	Send(*PublisherRequest) error
	Recv() (*Confirmation, error)
	grpc.ClientStream
}

type MessageSink_PublishServer 

type MessageSink_PublishServer interface {
	Send(*Confirmation) error
	Recv() (*PublisherRequest, error)
	grpc.ServerStream
}

type MessageSourceClient 

type MessageSourceClient interface {
	Consume(ctx context.Context, opts ...grpc.CallOption) (MessageSource_ConsumeClient, error)
}

MessageSourceClient is the client API for MessageSource 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 NewMessageSourceClient 

func NewMessageSourceClient(cc grpc.ClientConnInterface) MessageSourceClient

type MessageSourceServer 

type MessageSourceServer interface {
	Consume(MessageSource_ConsumeServer) error
}

MessageSourceServer is the server API for MessageSource service. All implementations should embed UnimplementedMessageSourceServer for forward compatibility

type MessageSource_ConsumeClient 

type MessageSource_ConsumeClient interface {
	Send(*ConsumerRequest) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type MessageSource_ConsumeServer 

type MessageSource_ConsumeServer interface {
	Send(*Message) error
	Recv() (*ConsumerRequest, error)
	grpc.ServerStream
}

type Offset 

type Offset int32
const (
	Offset_OFFSET_DEFAULT Offset = 0
	Offset_OFFSET_NEWEST  Offset = 1
	Offset_OFFSET_OLDEST  Offset = 2
)

func (Offset) Descriptor 

func (Offset) Descriptor() protoreflect.EnumDescriptor

func (Offset) Enum 

func (x Offset) Enum() *Offset

func (Offset) EnumDescriptor deprecated 

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

Deprecated: Use Offset.Descriptor instead.

func (Offset) Number 

func (x Offset) Number() protoreflect.EnumNumber

func (Offset) String 

func (x Offset) String() string

func (Offset) Type 

func (Offset) Type() protoreflect.EnumType

type PublisherRequest 

type PublisherRequest struct {

	// expected if this is a start request
	StartRequest *StartPublishRequest `protobuf:"bytes,2,opt,name=startRequest,proto3" json:"startRequest,omitempty"`
	// expected if this is a message
	Msg *Message `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PublisherRequest) Descriptor deprecated 

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

Deprecated: Use PublisherRequest.ProtoReflect.Descriptor instead.

func (*PublisherRequest) GetMsg 

func (x *PublisherRequest) GetMsg() *Message

func (*PublisherRequest) GetStartRequest 

func (x *PublisherRequest) GetStartRequest() *StartPublishRequest

func (*PublisherRequest) ProtoMessage 

func (*PublisherRequest) ProtoMessage()

func (*PublisherRequest) ProtoReflect 

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

func (*PublisherRequest) Reset 

func (x *PublisherRequest) Reset()

func (*PublisherRequest) String 

func (x *PublisherRequest) String() string

type StartConsumeRequest 

type StartConsumeRequest struct {
	Topic         string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Consumer      string `protobuf:"bytes,2,opt,name=consumer,proto3" json:"consumer,omitempty"`
	InitialOffset Offset `protobuf:"varint,3,opt,name=initial_offset,json=initialOffset,proto3,enum=proximo.Offset" json:"initial_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*StartConsumeRequest) Descriptor deprecated 

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

Deprecated: Use StartConsumeRequest.ProtoReflect.Descriptor instead.

func (*StartConsumeRequest) GetConsumer 

func (x *StartConsumeRequest) GetConsumer() string

func (*StartConsumeRequest) GetInitialOffset 

func (x *StartConsumeRequest) GetInitialOffset() Offset

func (*StartConsumeRequest) GetTopic 

func (x *StartConsumeRequest) GetTopic() string

func (*StartConsumeRequest) ProtoMessage 

func (*StartConsumeRequest) ProtoMessage()

func (*StartConsumeRequest) ProtoReflect 

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

func (*StartConsumeRequest) Reset 

func (x *StartConsumeRequest) Reset()

func (*StartConsumeRequest) String 

func (x *StartConsumeRequest) String() string

type StartPublishRequest 

type StartPublishRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*StartPublishRequest) Descriptor deprecated 

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

Deprecated: Use StartPublishRequest.ProtoReflect.Descriptor instead.

func (*StartPublishRequest) GetTopic 

func (x *StartPublishRequest) GetTopic() string

func (*StartPublishRequest) ProtoMessage 

func (*StartPublishRequest) ProtoMessage()

func (*StartPublishRequest) ProtoReflect 

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

func (*StartPublishRequest) Reset 

func (x *StartPublishRequest) Reset()

func (*StartPublishRequest) String 

func (x *StartPublishRequest) String() string

type UnimplementedMessageSinkServer 

type UnimplementedMessageSinkServer struct {
}

UnimplementedMessageSinkServer should be embedded to have forward compatible implementations.

func (UnimplementedMessageSinkServer) Publish 

func (UnimplementedMessageSinkServer) Publish(MessageSink_PublishServer) error

type UnimplementedMessageSourceServer 

type UnimplementedMessageSourceServer struct {
}

UnimplementedMessageSourceServer should be embedded to have forward compatible implementations.

func (UnimplementedMessageSourceServer) Consume 

func (UnimplementedMessageSourceServer) Consume(MessageSource_ConsumeServer) error

type UnsafeMessageSinkServer 

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

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

type UnsafeMessageSourceServer 

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

UnsafeMessageSourceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MessageSourceServer 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.