mq

Documentation

Index

• Constants
• func Flush() error
• func GetProtocolType() (protocol.TYPE, error)
• func Init(config lokas.IConfig) error
• func MarshalMsg(msg protocol.ISerializable) ([]byte, error)
• func PublishToActorOne(actorId util.ID, msg protocol.ISerializable) error
• func PublishToService(serviceType string, serviceId uint16, msg protocol.ISerializable) error
• func Publsih(key string, msg protocol.ISerializable) error
• func Request(key string, msg protocol.ISerializable) (protocol.ISerializable, error)
• func RequestToActorOne(actorId util.ID, msg protocol.ISerializable) (protocol.ISerializable, protocol.ErrCode)
• func TryReplyMessage(mqMsg *nats.Msg, msg protocol.ISerializable) error
• func UnmarshalMsg(data []byte) (protocol.ISerializable, error)
• type ActorSubscriber
  • func CreateActorSubscriber(actor lokas.IActor, ch chan *nats.Msg) (*ActorSubscriber, error)
  • func (this *ActorSubscriber) Drain()
  • func (this *ActorSubscriber) PublishToActorOne(actorId util.ID, msg protocol.ISerializable) error
  • func (this *ActorSubscriber) PublishToService(serviceType string, serviceId uint16, msg protocol.ISerializable) error
  • func (this *ActorSubscriber) Subscribe(subj string) error
  • func (this *ActorSubscriber) SubscribeForActor() error
  • func (this *ActorSubscriber) SubscribeForService(serviceType string, serviceId uint16) error
  • func (this *ActorSubscriber) UnSubscribeAll()
  • func (this *ActorSubscriber) Unsubscribe(subj string) error
• type MQHead
  • func UnmarshalHead(data []byte) (*MQHead, error)
• type MsgQueue
  • func Instance() *MsgQueue
  • func (this *MsgQueue) Flush() error
  • func (this *MsgQueue) MarshalMsg(msg protocol.ISerializable) ([]byte, error)
  • func (this *MsgQueue) UnmarshalHead(data []byte) (*MQHead, error)
  • func (this *MsgQueue) UnmarshalMsg(data []byte) (protocol.ISerializable, error)

Constants

const (
	KEY_ACTOR_BASE = "actor.one.%d"

	KEY_SERVICE_ID = "service.%s.%d"
)

Functions

func Flush

func Flush() error

func GetProtocolType

func GetProtocolType() (protocol.TYPE, error)

func Init

func Init(config lokas.IConfig) error

func MarshalMsg

func MarshalMsg(msg protocol.ISerializable) ([]byte, error)

func PublishToActorOne

func PublishToActorOne(actorId util.ID, msg protocol.ISerializable) error

func PublishToService

func PublishToService(serviceType string, serviceId uint16, msg protocol.ISerializable) error

func Publsih

func Publsih(key string, msg protocol.ISerializable) error

func Request

func Request(key string, msg protocol.ISerializable) (protocol.ISerializable, error)

func RequestToActorOne

func RequestToActorOne(actorId util.ID, msg protocol.ISerializable) (protocol.ISerializable, protocol.ErrCode)

func TryReplyMessage

func TryReplyMessage(mqMsg *nats.Msg, msg protocol.ISerializable) error

func UnmarshalMsg

func UnmarshalMsg(data []byte) (protocol.ISerializable, error)

Types

type ActorSubscriber

type ActorSubscriber struct {
	ActorId util.ID
	Pid     util.ProcessId
	MsgChan chan *nats.Msg
	// contains filtered or unexported fields
}

func CreateActorSubscriber

func CreateActorSubscriber(actor lokas.IActor, ch chan *nats.Msg) (*ActorSubscriber, error)

func (*ActorSubscriber) Drain

func (this *ActorSubscriber) Drain()

func (*ActorSubscriber) PublishToActorOne

func (this *ActorSubscriber) PublishToActorOne(actorId util.ID, msg protocol.ISerializable) error

func (*ActorSubscriber) PublishToService

func (this *ActorSubscriber) PublishToService(serviceType string, serviceId uint16, msg protocol.ISerializable) error

func (*ActorSubscriber) Subscribe

func (this *ActorSubscriber) Subscribe(subj string) error

func (*ActorSubscriber) SubscribeForActor

func (this *ActorSubscriber) SubscribeForActor() error

func (*ActorSubscriber) SubscribeForService

func (this *ActorSubscriber) SubscribeForService(serviceType string, serviceId uint16) error

func (*ActorSubscriber) UnSubscribeAll

func (this *ActorSubscriber) UnSubscribeAll()

func (*ActorSubscriber) Unsubscribe

func (this *ActorSubscriber) Unsubscribe(subj string) error

type MQHead

type MQHead struct {
	Len   uint16
	CmdId protocol.BINARY_TAG
	Body  []byte
}

func UnmarshalHead

func UnmarshalHead(data []byte) (*MQHead, error)

type MsgQueue

type MsgQueue struct {
	// contains filtered or unexported fields
}

func Instance

func Instance() *MsgQueue

func (*MsgQueue) Flush

func (this *MsgQueue) Flush() error

func (*MsgQueue) MarshalMsg

func (this *MsgQueue) MarshalMsg(msg protocol.ISerializable) ([]byte, error)

func (*MsgQueue) UnmarshalHead

func (this *MsgQueue) UnmarshalHead(data []byte) (*MQHead, error)

func (*MsgQueue) UnmarshalMsg

func (this *MsgQueue) UnmarshalMsg(data []byte) (protocol.ISerializable, error)