import "github.com/nats-io/stan.go/pb"
var ( ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group") )
var StartPosition_name = map[int32]string{ 0: "NewOnly", 1: "LastReceived", 2: "TimeDeltaStart", 3: "SequenceStart", 4: "First", }
var StartPosition_value = map[string]int32{ "NewOnly": 0, "LastReceived": 1, "TimeDeltaStart": 2, "SequenceStart": 3, "First": 4, }
type Ack struct { Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"` Sequence uint64 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` }
Ack will deliver an ack for a delivered msg.
type CloseRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` }
Protocol for a client to close a connection
func (*CloseRequest) Descriptor() ([]byte, []int)
func (m *CloseRequest) Marshal() (dAtA []byte, err error)
func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)
func (m *CloseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseRequest) ProtoMessage()
func (m *CloseRequest) Reset()
func (m *CloseRequest) Size() (n int)
func (m *CloseRequest) String() string
func (m *CloseRequest) Unmarshal(dAtA []byte) error
func (m *CloseRequest) XXX_DiscardUnknown()
func (m *CloseRequest) XXX_Merge(src proto.Message)
func (m *CloseRequest) XXX_Size() int
func (m *CloseRequest) XXX_Unmarshal(b []byte) error
type CloseResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` }
Response for CloseRequest
func (*CloseResponse) Descriptor() ([]byte, []int)
func (m *CloseResponse) Marshal() (dAtA []byte, err error)
func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)
func (m *CloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CloseResponse) ProtoMessage()
func (m *CloseResponse) Reset()
func (m *CloseResponse) Size() (n int)
func (m *CloseResponse) String() string
func (m *CloseResponse) Unmarshal(dAtA []byte) error
func (m *CloseResponse) XXX_DiscardUnknown()
func (m *CloseResponse) XXX_Merge(src proto.Message)
func (m *CloseResponse) XXX_Size() int
func (m *CloseResponse) XXX_Unmarshal(b []byte) error
type ConnectRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` HeartbeatInbox string `protobuf:"bytes,2,opt,name=heartbeatInbox,proto3" json:"heartbeatInbox,omitempty"` Protocol int32 `protobuf:"varint,3,opt,name=protocol,proto3" json:"protocol,omitempty"` ConnID []byte `protobuf:"bytes,4,opt,name=connID,proto3" json:"connID,omitempty"` PingInterval int32 `protobuf:"varint,5,opt,name=pingInterval,proto3" json:"pingInterval,omitempty"` PingMaxOut int32 `protobuf:"varint,6,opt,name=pingMaxOut,proto3" json:"pingMaxOut,omitempty"` }
Connection Request
func (*ConnectRequest) Descriptor() ([]byte, []int)
func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)
func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnectRequest) ProtoMessage()
func (m *ConnectRequest) Reset()
func (m *ConnectRequest) Size() (n int)
func (m *ConnectRequest) String() string
func (m *ConnectRequest) Unmarshal(dAtA []byte) error
func (m *ConnectRequest) XXX_DiscardUnknown()
func (m *ConnectRequest) XXX_Merge(src proto.Message)
func (m *ConnectRequest) XXX_Size() int
func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
type ConnectResponse struct { PubPrefix string `protobuf:"bytes,1,opt,name=pubPrefix,proto3" json:"pubPrefix,omitempty"` SubRequests string `protobuf:"bytes,2,opt,name=subRequests,proto3" json:"subRequests,omitempty"` UnsubRequests string `protobuf:"bytes,3,opt,name=unsubRequests,proto3" json:"unsubRequests,omitempty"` CloseRequests string `protobuf:"bytes,4,opt,name=closeRequests,proto3" json:"closeRequests,omitempty"` Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` SubCloseRequests string `protobuf:"bytes,6,opt,name=subCloseRequests,proto3" json:"subCloseRequests,omitempty"` PingRequests string `protobuf:"bytes,7,opt,name=pingRequests,proto3" json:"pingRequests,omitempty"` PingInterval int32 `protobuf:"varint,8,opt,name=pingInterval,proto3" json:"pingInterval,omitempty"` PingMaxOut int32 `protobuf:"varint,9,opt,name=pingMaxOut,proto3" json:"pingMaxOut,omitempty"` Protocol int32 `protobuf:"varint,10,opt,name=protocol,proto3" json:"protocol,omitempty"` PublicKey string `protobuf:"bytes,100,opt,name=publicKey,proto3" json:"publicKey,omitempty"` }
Response to a client connect
func (*ConnectResponse) Descriptor() ([]byte, []int)
func (m *ConnectResponse) Marshal() (dAtA []byte, err error)
func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error)
func (m *ConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnectResponse) ProtoMessage()
func (m *ConnectResponse) Reset()
func (m *ConnectResponse) Size() (n int)
func (m *ConnectResponse) String() string
func (m *ConnectResponse) Unmarshal(dAtA []byte) error
func (m *ConnectResponse) XXX_DiscardUnknown()
func (m *ConnectResponse) XXX_Merge(src proto.Message)
func (m *ConnectResponse) XXX_Size() int
func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
type MsgProto struct { Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` Reply string `protobuf:"bytes,3,opt,name=reply,proto3" json:"reply,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Redelivered bool `protobuf:"varint,6,opt,name=redelivered,proto3" json:"redelivered,omitempty"` RedeliveryCount uint32 `protobuf:"varint,7,opt,name=redeliveryCount,proto3" json:"redeliveryCount,omitempty"` CRC32 uint32 `protobuf:"varint,10,opt,name=CRC32,proto3" json:"CRC32,omitempty"` }
Msg struct. Sequence is assigned for global ordering by the cluster after the publisher has been acknowledged.
type Ping struct { ConnID []byte `protobuf:"bytes,1,opt,name=connID,proto3" json:"connID,omitempty"` }
PING from client to server
type PingResponse struct { Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` }
PING response from the server
func (*PingResponse) Descriptor() ([]byte, []int)
func (m *PingResponse) Marshal() (dAtA []byte, err error)
func (m *PingResponse) MarshalTo(dAtA []byte) (int, error)
func (m *PingResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PingResponse) ProtoMessage()
func (m *PingResponse) Reset()
func (m *PingResponse) Size() (n int)
func (m *PingResponse) String() string
func (m *PingResponse) Unmarshal(dAtA []byte) error
func (m *PingResponse) XXX_DiscardUnknown()
func (m *PingResponse) XXX_Merge(src proto.Message)
func (m *PingResponse) XXX_Size() int
func (m *PingResponse) XXX_Unmarshal(b []byte) error
type PubAck struct { Guid string `protobuf:"bytes,1,opt,name=guid,proto3" json:"guid,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` }
Used to ACK to publishers
type PubMsg struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` Guid string `protobuf:"bytes,2,opt,name=guid,proto3" json:"guid,omitempty"` Subject string `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"` Reply string `protobuf:"bytes,4,opt,name=reply,proto3" json:"reply,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` ConnID []byte `protobuf:"bytes,6,opt,name=connID,proto3" json:"connID,omitempty"` Sha256 []byte `protobuf:"bytes,10,opt,name=sha256,proto3" json:"sha256,omitempty"` }
How messages are delivered to the STAN cluster
Enum for start position type.
const ( StartPosition_NewOnly StartPosition = 0 StartPosition_LastReceived StartPosition = 1 StartPosition_TimeDeltaStart StartPosition = 2 StartPosition_SequenceStart StartPosition = 3 StartPosition_First StartPosition = 4 )
func (StartPosition) EnumDescriptor() ([]byte, []int)
func (x StartPosition) String() string
type SubscriptionRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` QGroup string `protobuf:"bytes,3,opt,name=qGroup,proto3" json:"qGroup,omitempty"` Inbox string `protobuf:"bytes,4,opt,name=inbox,proto3" json:"inbox,omitempty"` MaxInFlight int32 `protobuf:"varint,5,opt,name=maxInFlight,proto3" json:"maxInFlight,omitempty"` AckWaitInSecs int32 `protobuf:"varint,6,opt,name=ackWaitInSecs,proto3" json:"ackWaitInSecs,omitempty"` DurableName string `protobuf:"bytes,7,opt,name=durableName,proto3" json:"durableName,omitempty"` StartPosition StartPosition `protobuf:"varint,10,opt,name=startPosition,proto3,enum=pb.StartPosition" json:"startPosition,omitempty"` StartSequence uint64 `protobuf:"varint,11,opt,name=startSequence,proto3" json:"startSequence,omitempty"` StartTimeDelta int64 `protobuf:"varint,12,opt,name=startTimeDelta,proto3" json:"startTimeDelta,omitempty"` }
Protocol for a client to subscribe
func (*SubscriptionRequest) Descriptor() ([]byte, []int)
func (m *SubscriptionRequest) Marshal() (dAtA []byte, err error)
func (m *SubscriptionRequest) MarshalTo(dAtA []byte) (int, error)
func (m *SubscriptionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubscriptionRequest) ProtoMessage()
func (m *SubscriptionRequest) Reset()
func (m *SubscriptionRequest) Size() (n int)
func (m *SubscriptionRequest) String() string
func (m *SubscriptionRequest) Unmarshal(dAtA []byte) error
func (m *SubscriptionRequest) XXX_DiscardUnknown()
func (m *SubscriptionRequest) XXX_Merge(src proto.Message)
func (m *SubscriptionRequest) XXX_Size() int
func (m *SubscriptionRequest) XXX_Unmarshal(b []byte) error
type SubscriptionResponse struct { AckInbox string `protobuf:"bytes,2,opt,name=ackInbox,proto3" json:"ackInbox,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` }
Response for SubscriptionRequest and UnsubscribeRequests
func (*SubscriptionResponse) Descriptor() ([]byte, []int)
func (m *SubscriptionResponse) Marshal() (dAtA []byte, err error)
func (m *SubscriptionResponse) MarshalTo(dAtA []byte) (int, error)
func (m *SubscriptionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubscriptionResponse) ProtoMessage()
func (m *SubscriptionResponse) Reset()
func (m *SubscriptionResponse) Size() (n int)
func (m *SubscriptionResponse) String() string
func (m *SubscriptionResponse) Unmarshal(dAtA []byte) error
func (m *SubscriptionResponse) XXX_DiscardUnknown()
func (m *SubscriptionResponse) XXX_Merge(src proto.Message)
func (m *SubscriptionResponse) XXX_Size() int
func (m *SubscriptionResponse) XXX_Unmarshal(b []byte) error
type UnsubscribeRequest struct { ClientID string `protobuf:"bytes,1,opt,name=clientID,proto3" json:"clientID,omitempty"` Subject string `protobuf:"bytes,2,opt,name=subject,proto3" json:"subject,omitempty"` Inbox string `protobuf:"bytes,3,opt,name=inbox,proto3" json:"inbox,omitempty"` DurableName string `protobuf:"bytes,4,opt,name=durableName,proto3" json:"durableName,omitempty"` }
Protocol for a clients to unsubscribe. Will return a SubscriptionResponse
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)
func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)
func (m *UnsubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UnsubscribeRequest) ProtoMessage()
func (m *UnsubscribeRequest) Reset()
func (m *UnsubscribeRequest) Size() (n int)
func (m *UnsubscribeRequest) String() string
func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error
func (m *UnsubscribeRequest) XXX_DiscardUnknown()
func (m *UnsubscribeRequest) XXX_Merge(src proto.Message)
func (m *UnsubscribeRequest) XXX_Size() int
func (m *UnsubscribeRequest) XXX_Unmarshal(b []byte) error
Package pb imports 6 packages (graph) and is imported by 18 packages. Updated 2021-01-12. Refresh now. Tools for package owners.