serverv1

Documentation

Index

• Variables
• type Consumer
  • func (*Consumer) Descriptor() ([]byte, []int)
  • func (x *Consumer) GetId() string
  • func (*Consumer) ProtoMessage()
  • func (x *Consumer) ProtoReflect() protoreflect.Message
  • func (x *Consumer) Reset()
  • func (x *Consumer) String() string
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetAction() isMessage_Action
  • func (x *Message) GetCron() *v1.Cron
  • func (x *Message) GetEvent() *v1.Event
  • func (x *Message) GetEventTime() *timestamppb.Timestamp
  • func (x *Message) GetHeader() map[string]string
  • func (x *Message) GetId() string
  • func (x *Message) GetMessage() *anypb.Any
  • func (x *Message) GetSubject() string
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Message_Cron
• type Message_Event
• type Stream
  • func (*Stream) Descriptor() ([]byte, []int)
  • func (x *Stream) GetAckWait() *timestamppb.Timestamp
  • func (x *Stream) GetId() string
  • func (x *Stream) GetMaxDeliver() int32
  • func (x *Stream) GetName() string
  • func (x *Stream) GetPolicy() v1.AckPolicy
  • func (x *Stream) GetReplicas() string
  • func (x *Stream) GetSubject() string
  • func (*Stream) ProtoMessage()
  • func (x *Stream) ProtoReflect() protoreflect.Message
  • func (x *Stream) Reset()
  • func (x *Stream) String() string

Variables

var File_server_v1_server_proto protoreflect.FileDescriptor

Types

type Consumer

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

func (*Consumer) Descriptor

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

Deprecated: Use Consumer.ProtoReflect.Descriptor instead.

func (*Consumer) GetId

func (x *Consumer) GetId() string

func (*Consumer) ProtoMessage

func (*Consumer) ProtoMessage()

func (*Consumer) ProtoReflect

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

func (*Consumer) Reset

func (x *Consumer) Reset()

func (*Consumer) String

func (x *Consumer) String() string

type Message

type Message struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Subject   string                 `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	Header    map[string]string      `` /* 153-byte string literal not displayed */
	Message   *anypb.Any             `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// Types that are assignable to Action:
	//
	//	*Message_Event
	//	*Message_Cron
	Action isMessage_Action `protobuf_oneof:"action"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetAction

func (m *Message) GetAction() isMessage_Action

func (*Message) GetCron

func (x *Message) GetCron() *v1.Cron

func (*Message) GetEvent

func (x *Message) GetEvent() *v1.Event

func (*Message) GetEventTime

func (x *Message) GetEventTime() *timestamppb.Timestamp

func (*Message) GetHeader

func (x *Message) GetHeader() map[string]string

func (*Message) GetId

func (x *Message) GetId() string

func (*Message) GetMessage

func (x *Message) GetMessage() *anypb.Any

func (*Message) GetSubject

func (x *Message) GetSubject() string

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 Message_Cron

type Message_Cron struct {
	Cron *v1.Cron `protobuf:"bytes,7,opt,name=cron,proto3,oneof"`
}

type Message_Event

type Message_Event struct {
	Event *v1.Event `protobuf:"bytes,6,opt,name=event,proto3,oneof"`
}

type Stream

type Stream struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Subject    string                 `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	Policy     v1.AckPolicy           `protobuf:"varint,4,opt,name=policy,proto3,enum=common.v1.AckPolicy" json:"policy,omitempty"`
	Replicas   string                 `protobuf:"bytes,5,opt,name=replicas,proto3" json:"replicas,omitempty"`
	MaxDeliver int32                  `protobuf:"varint,6,opt,name=max_deliver,json=maxDeliver,proto3" json:"max_deliver,omitempty"`
	AckWait    *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=ack_wait,json=ackWait,proto3" json:"ack_wait,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetAckWait

func (x *Stream) GetAckWait() *timestamppb.Timestamp

func (*Stream) GetId

func (x *Stream) GetId() string

func (*Stream) GetMaxDeliver

func (x *Stream) GetMaxDeliver() int32

func (*Stream) GetName

func (x *Stream) GetName() string

func (*Stream) GetPolicy

func (x *Stream) GetPolicy() v1.AckPolicy

func (*Stream) GetReplicas

func (x *Stream) GetReplicas() string

func (*Stream) GetSubject

func (x *Stream) GetSubject() string

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect

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

func (*Stream) Reset

func (x *Stream) Reset()

func (*Stream) String

func (x *Stream) String() string