import "github.com/nats-io/stan.go/pb"
Package pb is a generated protocol buffer package.
It is generated from these files:
protocol.proto
It has these top-level messages:
PubMsg PubAck MsgProto Ack ConnectRequest ConnectResponse Ping PingResponse SubscriptionRequest SubscriptionResponse UnsubscribeRequest CloseRequest CloseResponse
var (
ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow")
)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 (*CloseRequest) ProtoMessage()
func (m *CloseRequest) Reset()
func (m *CloseRequest) Size() (n int)
func (m *CloseRequest) String() string
func (m *CloseRequest) Unmarshal(dAtA []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 (*CloseResponse) ProtoMessage()
func (m *CloseResponse) Reset()
func (m *CloseResponse) Size() (n int)
func (m *CloseResponse) String() string
func (m *CloseResponse) Unmarshal(dAtA []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 (*ConnectRequest) ProtoMessage()
func (m *ConnectRequest) Reset()
func (m *ConnectRequest) Size() (n int)
func (m *ConnectRequest) String() string
func (m *ConnectRequest) Unmarshal(dAtA []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 (*ConnectResponse) ProtoMessage()
func (m *ConnectResponse) Reset()
func (m *ConnectResponse) Size() (n int)
func (m *ConnectResponse) String() string
func (m *ConnectResponse) Unmarshal(dAtA []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 (*PingResponse) ProtoMessage()
func (m *PingResponse) Reset()
func (m *PingResponse) Size() (n int)
func (m *PingResponse) String() string
func (m *PingResponse) Unmarshal(dAtA []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 (*SubscriptionRequest) ProtoMessage()
func (m *SubscriptionRequest) Reset()
func (m *SubscriptionRequest) Size() (n int)
func (m *SubscriptionRequest) String() string
func (m *SubscriptionRequest) Unmarshal(dAtA []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 (*SubscriptionResponse) ProtoMessage()
func (m *SubscriptionResponse) Reset()
func (m *SubscriptionResponse) Size() (n int)
func (m *SubscriptionResponse) String() string
func (m *SubscriptionResponse) Unmarshal(dAtA []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 (*UnsubscribeRequest) ProtoMessage()
func (m *UnsubscribeRequest) Reset()
func (m *UnsubscribeRequest) Size() (n int)
func (m *UnsubscribeRequest) String() string
func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error
Package pb imports 5 packages (graph) and is imported by 17 packages. Updated 2019-12-18. Refresh now. Tools for package owners.