pb

package
v0.4.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 16, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

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

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProtocol   = fmt.Errorf("proto: integer overflow")
)
View Source 
var StartPosition_name = map[int32]string{
	0: "NewOnly",
	1: "LastReceived",
	2: "TimeDeltaStart",
	3: "SequenceStart",
	4: "First",
}
View Source 
var StartPosition_value = map[string]int32{
	"NewOnly":        0,
	"LastReceived":   1,
	"TimeDeltaStart": 2,
	"SequenceStart":  3,
	"First":          4,
}

Functions

This section is empty.

Types

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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"`
	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 added in v0.4.0 

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 added in v0.4.0 

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

PING from client to server

func (*Ping) Descriptor added in v0.4.0 

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

func (*Ping) Marshal added in v0.4.0 

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

func (*Ping) MarshalTo added in v0.4.0 

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

func (*Ping) ProtoMessage added in v0.4.0 

func (*Ping) ProtoMessage()

func (*Ping) Reset added in v0.4.0 

func (m *Ping) Reset()

func (*Ping) Size added in v0.4.0 

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

func (*Ping) String added in v0.4.0 

func (m *Ping) String() string

func (*Ping) Unmarshal added in v0.4.0 

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

type PingResponse added in v0.4.0 

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

PING response from the server

func (*PingResponse) Descriptor added in v0.4.0 

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

func (*PingResponse) Marshal added in v0.4.0 

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

func (*PingResponse) MarshalTo added in v0.4.0 

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

func (*PingResponse) ProtoMessage added in v0.4.0 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset added in v0.4.0 

func (m *PingResponse) Reset()

func (*PingResponse) Size added in v0.4.0 

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

func (*PingResponse) String added in v0.4.0 

func (m *PingResponse) String() string

func (*PingResponse) Unmarshal added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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 added in v0.4.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.