pb

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2016 License: MIT Imports: 5 Imported by: 39

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
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) 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) 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) 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"`
}

Connection Request

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"`
	PublicKey     string `protobuf:"bytes,100,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
}

Response to a client connect

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) 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 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) 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"`
	Sha256   []byte `protobuf:"bytes,10,opt,name=sha256,proto3" json:"sha256,omitempty"`
}

How messages are delivered to the STAN cluster

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