stan.go: github.com/nats-io/stan.go/pb Index | Files

package pb

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

Index

Package Files

protocol.pb.go

Variables

❖
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 Uses

❖
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.

func (*Ack) Descriptor Uses

❖
func (*Ack) Descriptor() ([]byte, []int)

func (*Ack) Marshal Uses

❖
func (m *Ack) Marshal() (dAtA []byte, err error)

func (*Ack) MarshalTo Uses

❖
func (m *Ack) MarshalTo(dAtA []byte) (int, error)

func (*Ack) ProtoMessage Uses

❖
func (*Ack) ProtoMessage()

func (*Ack) Reset Uses

❖
func (m *Ack) Reset()

func (*Ack) Size Uses

❖
func (m *Ack) Size() (n int)

func (*Ack) String Uses

❖
func (m *Ack) String() string

func (*Ack) Unmarshal Uses

❖
func (m *Ack) Unmarshal(dAtA []byte) error

type CloseRequest Uses

❖
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 Uses

❖
func (*CloseRequest) Descriptor() ([]byte, []int)

func (*CloseRequest) Marshal Uses

❖
func (m *CloseRequest) Marshal() (dAtA []byte, err error)

func (*CloseRequest) MarshalTo Uses

❖
func (m *CloseRequest) MarshalTo(dAtA []byte) (int, error)

func (*CloseRequest) ProtoMessage Uses

❖
func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset Uses

❖
func (m *CloseRequest) Reset()

func (*CloseRequest) Size Uses

❖
func (m *CloseRequest) Size() (n int)

func (*CloseRequest) String Uses

❖
func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal Uses

❖
func (m *CloseRequest) Unmarshal(dAtA []byte) error

type CloseResponse Uses

❖
type CloseResponse struct {
    Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

Response for CloseRequest

func (*CloseResponse) Descriptor Uses

❖
func (*CloseResponse) Descriptor() ([]byte, []int)

func (*CloseResponse) Marshal Uses

❖
func (m *CloseResponse) Marshal() (dAtA []byte, err error)

func (*CloseResponse) MarshalTo Uses

❖
func (m *CloseResponse) MarshalTo(dAtA []byte) (int, error)

func (*CloseResponse) ProtoMessage Uses

❖
func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset Uses

❖
func (m *CloseResponse) Reset()

func (*CloseResponse) Size Uses

❖
func (m *CloseResponse) Size() (n int)

func (*CloseResponse) String Uses

❖
func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal Uses

❖
func (m *CloseResponse) Unmarshal(dAtA []byte) error

type ConnectRequest Uses

❖
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 Uses

❖
func (*ConnectRequest) Descriptor() ([]byte, []int)

func (*ConnectRequest) Marshal Uses

❖
func (m *ConnectRequest) Marshal() (dAtA []byte, err error)

func (*ConnectRequest) MarshalTo Uses

❖
func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConnectRequest) ProtoMessage Uses

❖
func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset Uses

❖
func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size Uses

❖
func (m *ConnectRequest) Size() (n int)

func (*ConnectRequest) String Uses

❖
func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal Uses

❖
func (m *ConnectRequest) Unmarshal(dAtA []byte) error

type ConnectResponse Uses

❖
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 Uses

❖
func (*ConnectResponse) Descriptor() ([]byte, []int)

func (*ConnectResponse) Marshal Uses

❖
func (m *ConnectResponse) Marshal() (dAtA []byte, err error)

func (*ConnectResponse) MarshalTo Uses

❖
func (m *ConnectResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConnectResponse) ProtoMessage Uses

❖
func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset Uses

❖
func (m *ConnectResponse) Reset()

func (*ConnectResponse) Size Uses

❖
func (m *ConnectResponse) Size() (n int)

func (*ConnectResponse) String Uses

❖
func (m *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal Uses

❖
func (m *ConnectResponse) Unmarshal(dAtA []byte) error

type MsgProto Uses

❖
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"`
    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.

func (*MsgProto) Descriptor Uses

❖
func (*MsgProto) Descriptor() ([]byte, []int)

func (*MsgProto) Marshal Uses

❖
func (m *MsgProto) Marshal() (dAtA []byte, err error)

func (*MsgProto) MarshalTo Uses

❖
func (m *MsgProto) MarshalTo(dAtA []byte) (int, error)

func (*MsgProto) ProtoMessage Uses

❖
func (*MsgProto) ProtoMessage()

func (*MsgProto) Reset Uses

❖
func (m *MsgProto) Reset()

func (*MsgProto) Size Uses

❖
func (m *MsgProto) Size() (n int)

func (*MsgProto) String Uses

❖
func (m *MsgProto) String() string

func (*MsgProto) Unmarshal Uses

❖
func (m *MsgProto) Unmarshal(dAtA []byte) error

type Ping Uses

❖
type Ping struct {
    ConnID []byte `protobuf:"bytes,1,opt,name=connID,proto3" json:"connID,omitempty"`
}

PING from client to server

func (*Ping) Descriptor Uses

❖
func (*Ping) Descriptor() ([]byte, []int)

func (*Ping) Marshal Uses

❖
func (m *Ping) Marshal() (dAtA []byte, err error)

func (*Ping) MarshalTo Uses

❖
func (m *Ping) MarshalTo(dAtA []byte) (int, error)

func (*Ping) ProtoMessage Uses

❖
func (*Ping) ProtoMessage()

func (*Ping) Reset Uses

❖
func (m *Ping) Reset()

func (*Ping) Size Uses

❖
func (m *Ping) Size() (n int)

func (*Ping) String Uses

❖
func (m *Ping) String() string

func (*Ping) Unmarshal Uses

❖
func (m *Ping) Unmarshal(dAtA []byte) error

type PingResponse Uses

❖
type PingResponse struct {
    Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

PING response from the server

func (*PingResponse) Descriptor Uses

❖
func (*PingResponse) Descriptor() ([]byte, []int)

func (*PingResponse) Marshal Uses

❖
func (m *PingResponse) Marshal() (dAtA []byte, err error)

func (*PingResponse) MarshalTo Uses

❖
func (m *PingResponse) MarshalTo(dAtA []byte) (int, error)

func (*PingResponse) ProtoMessage Uses

❖
func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset Uses

❖
func (m *PingResponse) Reset()

func (*PingResponse) Size Uses

❖
func (m *PingResponse) Size() (n int)

func (*PingResponse) String Uses

❖
func (m *PingResponse) String() string

func (*PingResponse) Unmarshal Uses

❖
func (m *PingResponse) Unmarshal(dAtA []byte) error

type PubAck Uses

❖
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

func (*PubAck) Descriptor Uses

❖
func (*PubAck) Descriptor() ([]byte, []int)

func (*PubAck) Marshal Uses

❖
func (m *PubAck) Marshal() (dAtA []byte, err error)

func (*PubAck) MarshalTo Uses

❖
func (m *PubAck) MarshalTo(dAtA []byte) (int, error)

func (*PubAck) ProtoMessage Uses

❖
func (*PubAck) ProtoMessage()

func (*PubAck) Reset Uses

❖
func (m *PubAck) Reset()

func (*PubAck) Size Uses

❖
func (m *PubAck) Size() (n int)

func (*PubAck) String Uses

❖
func (m *PubAck) String() string

func (*PubAck) Unmarshal Uses

❖
func (m *PubAck) Unmarshal(dAtA []byte) error

type PubMsg Uses

❖
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

func (*PubMsg) Descriptor Uses

❖
func (*PubMsg) Descriptor() ([]byte, []int)

func (*PubMsg) Marshal Uses

❖
func (m *PubMsg) Marshal() (dAtA []byte, err error)

func (*PubMsg) MarshalTo Uses

❖
func (m *PubMsg) MarshalTo(dAtA []byte) (int, error)

func (*PubMsg) ProtoMessage Uses

❖
func (*PubMsg) ProtoMessage()

func (*PubMsg) Reset Uses

❖
func (m *PubMsg) Reset()

func (*PubMsg) Size Uses

❖
func (m *PubMsg) Size() (n int)

func (*PubMsg) String Uses

❖
func (m *PubMsg) String() string

func (*PubMsg) Unmarshal Uses

❖
func (m *PubMsg) Unmarshal(dAtA []byte) error

type StartPosition Uses

❖
type StartPosition int32

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 Uses

❖
func (StartPosition) EnumDescriptor() ([]byte, []int)

func (StartPosition) String Uses

❖
func (x StartPosition) String() string

type SubscriptionRequest Uses

❖
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 Uses

❖
func (*SubscriptionRequest) Descriptor() ([]byte, []int)

func (*SubscriptionRequest) Marshal Uses

❖
func (m *SubscriptionRequest) Marshal() (dAtA []byte, err error)

func (*SubscriptionRequest) MarshalTo Uses

❖
func (m *SubscriptionRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscriptionRequest) ProtoMessage Uses

❖
func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) Reset Uses

❖
func (m *SubscriptionRequest) Reset()

func (*SubscriptionRequest) Size Uses

❖
func (m *SubscriptionRequest) Size() (n int)

func (*SubscriptionRequest) String Uses

❖
func (m *SubscriptionRequest) String() string

func (*SubscriptionRequest) Unmarshal Uses

❖
func (m *SubscriptionRequest) Unmarshal(dAtA []byte) error

type SubscriptionResponse Uses

❖
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 Uses

❖
func (*SubscriptionResponse) Descriptor() ([]byte, []int)

func (*SubscriptionResponse) Marshal Uses

❖
func (m *SubscriptionResponse) Marshal() (dAtA []byte, err error)

func (*SubscriptionResponse) MarshalTo Uses

❖
func (m *SubscriptionResponse) MarshalTo(dAtA []byte) (int, error)

func (*SubscriptionResponse) ProtoMessage Uses

❖
func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) Reset Uses

❖
func (m *SubscriptionResponse) Reset()

func (*SubscriptionResponse) Size Uses

❖
func (m *SubscriptionResponse) Size() (n int)

func (*SubscriptionResponse) String Uses

❖
func (m *SubscriptionResponse) String() string

func (*SubscriptionResponse) Unmarshal Uses

❖
func (m *SubscriptionResponse) Unmarshal(dAtA []byte) error

type UnsubscribeRequest Uses

❖
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 Uses

❖
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)

func (*UnsubscribeRequest) Marshal Uses

❖
func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)

func (*UnsubscribeRequest) MarshalTo Uses

❖
func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnsubscribeRequest) ProtoMessage Uses

❖
func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) Reset Uses

❖
func (m *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) Size Uses

❖
func (m *UnsubscribeRequest) Size() (n int)

func (*UnsubscribeRequest) String Uses

❖
func (m *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) Unmarshal Uses

❖
func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error

Package pb imports 5 packages (graph) and is imported by 13 packages. Updated 2019-05-10. Refresh now. Tools for package owners.