Documentation
¶
Overview ¶
Package goclient : File ClientGandalf.go
Index ¶
- type 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) SendReply ¶
func (cg ClientGandalf) SendReply(topic, event, referenceUUID string, options map[string]string) (empty *pb.Empty)
SendReply
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
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package command : File clientBase.go
|
Package command : File clientBase.go |
|
Package client : File ClientGrpc.go
|
Package client : File ClientGrpc.go |
|
Package command : File ClientCommand.go
|
Package command : File ClientCommand.go |
|
Package configuration : File ClientConfiguration.go
|
Package configuration : File ClientConfiguration.go |
|
Package event : File ClientEvent.go
|
Package event : File ClientEvent.go |
Click to show internal directories.
Click to hide internal directories.