goclient

Documentation

Overview

Package goclient : File ClientGandalf.go

Index

• type ClientGandalf
  • func NewClientGandalf(identity, timeout string, clientConnections []string) (clientGandalf *ClientGandalf)
  • func (cg ClientGandalf) CreateIteratorCommand() string
  • func (cg ClientGandalf) CreateIteratorEvent() string
  • func (cg ClientGandalf) SendAdminCommand(request string, options map[string]string) string
  • func (cg ClientGandalf) SendCommand(request string, options map[string]string) string
  • func (cg ClientGandalf) SendCommandList(major, minor int64, commands []string) bool
  • func (cg ClientGandalf) SendEvent(topic, event string, options map[string]string) (empty *pb.Empty)
  • func (cg ClientGandalf) SendReply(topic, event, referenceUUID string, options map[string]string) (empty *pb.Empty)
  • func (cg ClientGandalf) SendStop(major, minor int64) bool
  • func (cg ClientGandalf) WaitAllReplyByTopic(topic, referenceUUID, idIterator string) (eventMessages []msg.Event)
  • func (cg ClientGandalf) WaitCommand(command, idIterator string, version int64) (commandMessage msg.Command)
  • func (cg ClientGandalf) WaitEvent(topic, event, idIterator string) (eventMessage msg.Event)
  • func (cg ClientGandalf) WaitReplyByEvent(topic, event, referenceUUID, idIterator string) (eventMessage msg.Event)
  • func (cg ClientGandalf) WaitReplyByTopic(topic, referenceUUID, idIterator string) (eventMessage msg.Event)
  • func (cg ClientGandalf) WaitTopic(topic, idIterator string) (eventMessage msg.Event)

Types

type ClientGandalf

type ClientGandalf struct {
	Identity          string
	ClientConnections []string
	Clients           []*client.ClientGrpc
	ClientStopChannel chan int
	Timeout           string
}

ClientGandalf :

func NewClientGandalf

func NewClientGandalf(identity, timeout string, clientConnections []string) (clientGandalf *ClientGandalf)

NewClientGandalf

func (ClientGandalf) CreateIteratorCommand

func (cg ClientGandalf) CreateIteratorCommand() string

CreateIteratorCommand

func (ClientGandalf) CreateIteratorEvent

func (cg ClientGandalf) CreateIteratorEvent() string

CreateIteratorEvent

func (ClientGandalf) SendAdminCommand

func (cg ClientGandalf) SendAdminCommand(request string, options map[string]string) string

SendAdminCommand

func (ClientGandalf) SendCommand

func (cg ClientGandalf) SendCommand(request string, options map[string]string) string

SendCommand

func (ClientGandalf) SendCommandList

func (cg ClientGandalf) SendCommandList(major, minor int64, commands []string) bool

SendCommandList

func (ClientGandalf) SendEvent

func (cg ClientGandalf) SendEvent(topic, event string, options map[string]string) (empty *pb.Empty)

SendEvent

func (ClientGandalf) SendReply

func (cg ClientGandalf) SendReply(topic, event, referenceUUID string, options map[string]string) (empty *pb.Empty)

SendReply

func (ClientGandalf) SendStop

func (cg ClientGandalf) SendStop(major, minor int64) bool

SendStop

func (ClientGandalf) WaitAllReplyByTopic

func (cg ClientGandalf) WaitAllReplyByTopic(topic, referenceUUID, idIterator string) (eventMessages []msg.Event)

WaitAllReplyByTopic

func (ClientGandalf) WaitCommand

func (cg ClientGandalf) WaitCommand(command, idIterator string, version int64) (commandMessage msg.Command)

WaitCommand

func (ClientGandalf) WaitEvent

func (cg ClientGandalf) WaitEvent(topic, event, idIterator string) (eventMessage msg.Event)

WaitEvent

func (ClientGandalf) WaitReplyByEvent

func (cg ClientGandalf) WaitReplyByEvent(topic, event, referenceUUID, idIterator string) (eventMessage msg.Event)

WaitReplyByEvent

func (ClientGandalf) WaitReplyByTopic

func (cg ClientGandalf) WaitReplyByTopic(topic, referenceUUID, idIterator string) (eventMessage msg.Event)

WaitReplyByTopic

func (ClientGandalf) WaitTopic

func (cg ClientGandalf) WaitTopic(topic, idIterator string) (eventMessage msg.Event)

WaitTopic