command

Documentation

Index

• Constants
• type CorrelatedMessage
  • func (m *CorrelatedMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight
• type ImageMessage
  • func (m *ImageMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight
• type PublicationMessage
  • func (m *PublicationMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight
• type RemoveMessage
  • func (m *RemoveMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight
• type SubscriptionMessage
  • func (m *SubscriptionMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

Constants

const (

	// AddPublication command from client
	AddPublication int32 = 0x01
	// RemovePublication command from client
	RemovePublication int32 = 0x02
	// Add Exclusive Publication
	AddExclusivePublication int32 = 0x03
	// AddSubscription command from client
	AddSubscription int32 = 0x04
	// RemoveSubscription command from client
	RemoveSubscription int32 = 0x05
	// ClientKeepalive message from client */
	ClientKeepalive int32 = 0x06

	AddDestination = 0x07
	// Remove Destination
	RemoveDestination = 0x08
	// Add Counter
	AddCounter = 0x09
	// Remove Counter
	RemoveCounter = 0x0A
	// Client Close
	ClientClose = 0x0B
)

Types

type CorrelatedMessage

type CorrelatedMessage struct {
	flyweight.FWBase

	ClientID      flyweight.Int64Field
	CorrelationID flyweight.Int64Field
}

func (*CorrelatedMessage) Wrap

func (m *CorrelatedMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

type ImageMessage

type ImageMessage struct {
	flyweight.FWBase

	CorrelationID              flyweight.Int64Field
	SubscriptionRegistrationID flyweight.Int64Field
	StreamID                   flyweight.Int32Field
	Channel                    flyweight.StringField
}

func (*ImageMessage) Wrap

func (m *ImageMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

type PublicationMessage

type PublicationMessage struct {
	flyweight.FWBase

	ClientID      flyweight.Int64Field
	CorrelationID flyweight.Int64Field
	StreamID      flyweight.Int32Field
	Channel       flyweight.StringField
}

func (*PublicationMessage) Wrap

func (m *PublicationMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

type RemoveMessage

type RemoveMessage struct {
	flyweight.FWBase

	ClientID       flyweight.Int64Field
	CorrelationID  flyweight.Int64Field
	RegistrationID flyweight.Int64Field
}

func (*RemoveMessage) Wrap

func (m *RemoveMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight

type SubscriptionMessage

type SubscriptionMessage struct {
	flyweight.FWBase

	ClientID                  flyweight.Int64Field
	CorrelationID             flyweight.Int64Field
	RegistrationCorrelationID flyweight.Int64Field
	StreamID                  flyweight.Int32Field
	Channel                   flyweight.StringField
}

func (*SubscriptionMessage) Wrap

func (m *SubscriptionMessage) Wrap(buf *atomic.Buffer, offset int) flyweight.Flyweight