Back to godoc.org

Package pb

v0.7.0
Latest Go to latest
Published: Jun 23, 2020 | License: Apache-2.0 | Module: github.com/nats-io/stan.go

Overview

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

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

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

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

func (*Ack) Marshal

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

func (*Ack) MarshalTo

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

func (*Ack) ProtoMessage

func (*Ack) ProtoMessage()

func (*Ack) Reset

func (m *Ack) Reset()

func (*Ack) Size

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

func (*Ack) String

func (m *Ack) String() string

func (*Ack) Unmarshal

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

type CloseRequest

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

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

func (*CloseRequest) Marshal

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

func (*CloseRequest) MarshalTo

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

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset

func (m *CloseRequest) Reset()

func (*CloseRequest) Size

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

func (*CloseRequest) String

func (m *CloseRequest) String() string

func (*CloseRequest) Unmarshal

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

type CloseResponse

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

Response for CloseRequest

func (*CloseResponse) Descriptor

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

func (*CloseResponse) Marshal

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

func (*CloseResponse) MarshalTo

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

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) Reset

func (m *CloseResponse) Reset()

func (*CloseResponse) Size

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

func (*CloseResponse) String

func (m *CloseResponse) String() string

func (*CloseResponse) Unmarshal

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

type ConnectRequest

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

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

func (*ConnectRequest) Marshal

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

func (*ConnectRequest) MarshalTo

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

func (*ConnectRequest) ProtoMessage

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset

func (m *ConnectRequest) Reset()

func (*ConnectRequest) Size

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

func (*ConnectRequest) String

func (m *ConnectRequest) String() string

func (*ConnectRequest) Unmarshal

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

type ConnectResponse

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

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

func (*ConnectResponse) Marshal

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

func (*ConnectResponse) MarshalTo

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

func (*ConnectResponse) ProtoMessage

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset

func (m *ConnectResponse) Reset()

func (*ConnectResponse) Size

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

func (*ConnectResponse) String

func (m *ConnectResponse) String() string

func (*ConnectResponse) Unmarshal

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

type MsgProto

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.

func (*MsgProto) Descriptor

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

func (*MsgProto) Marshal

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

func (*MsgProto) MarshalTo

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

func (*MsgProto) ProtoMessage

func (*MsgProto) ProtoMessage()

func (*MsgProto) Reset

func (m *MsgProto) Reset()

func (*MsgProto) Size

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

func (*MsgProto) String

func (m *MsgProto) String() string

func (*MsgProto) Unmarshal

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

type Ping

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

PING from client to server

func (*Ping) Descriptor

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

func (*Ping) Marshal

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

func (*Ping) MarshalTo

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

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) Reset

func (m *Ping) Reset()

func (*Ping) Size

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

func (*Ping) String

func (m *Ping) String() string

func (*Ping) Unmarshal

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

type PingResponse

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

PING response from the server

func (*PingResponse) Descriptor

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

func (*PingResponse) Marshal

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

func (*PingResponse) MarshalTo

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

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset

func (m *PingResponse) Reset()

func (*PingResponse) Size

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

func (*PingResponse) String

func (m *PingResponse) String() string

func (*PingResponse) Unmarshal

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

type PubAck

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

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

func (*PubAck) Marshal

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

func (*PubAck) MarshalTo

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

func (*PubAck) ProtoMessage

func (*PubAck) ProtoMessage()

func (*PubAck) Reset

func (m *PubAck) Reset()

func (*PubAck) Size

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

func (*PubAck) String

func (m *PubAck) String() string

func (*PubAck) Unmarshal

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

type PubMsg

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

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

func (*PubMsg) Marshal

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

func (*PubMsg) MarshalTo

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

func (*PubMsg) ProtoMessage

func (*PubMsg) ProtoMessage()

func (*PubMsg) Reset

func (m *PubMsg) Reset()

func (*PubMsg) Size

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

func (*PubMsg) String

func (m *PubMsg) String() string

func (*PubMsg) Unmarshal

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

type StartPosition

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

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

func (StartPosition) String

func (x StartPosition) String() string

type SubscriptionRequest

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

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

func (*SubscriptionRequest) Marshal

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

func (*SubscriptionRequest) MarshalTo

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

func (*SubscriptionRequest) ProtoMessage

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) Reset

func (m *SubscriptionRequest) Reset()

func (*SubscriptionRequest) Size

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

func (*SubscriptionRequest) String

func (m *SubscriptionRequest) String() string

func (*SubscriptionRequest) Unmarshal

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

type SubscriptionResponse

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

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

func (*SubscriptionResponse) Marshal

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

func (*SubscriptionResponse) MarshalTo

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

func (*SubscriptionResponse) ProtoMessage

func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) Reset

func (m *SubscriptionResponse) Reset()

func (*SubscriptionResponse) Size

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

func (*SubscriptionResponse) String

func (m *SubscriptionResponse) String() string

func (*SubscriptionResponse) Unmarshal

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

type UnsubscribeRequest

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

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

func (*UnsubscribeRequest) Marshal

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

func (*UnsubscribeRequest) MarshalTo

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

func (*UnsubscribeRequest) ProtoMessage

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) Reset

func (m *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) Size

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

func (*UnsubscribeRequest) String

func (m *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) Unmarshal

func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error
Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier