gmclient

Documentation

Index

• Constants
• type ClientI
  • func NewWebSocketClient(options *options.LocalControllerOptions) ClientI
• type Message
• type MessageHeader
• type MessageResourceHandler
• type WSConnection

Constants

const (
	// InsertOperation is the insert value
	InsertOperation = "insert"
	// DeleteOperation is the delete value
	DeleteOperation = "delete"
	// StatusOperation is the status value
	StatusOperation = "status"
)

const (
	// RetryCount is count of retrying to connecting to global manager
	RetryCount = 5
	// RetryConnectIntervalSeconds is interval time of retrying to connecting to global manager
	RetryConnectIntervalSeconds = 5
	// MessageChannelCacheSize is size of channel cache
	MessageChannelCacheSize = 100
)

Types

type ClientI

type ClientI interface {
	Start() error
	WriteMessage(messageBody interface{}, messageHeader MessageHeader) error
	Subscribe(m MessageResourceHandler) error
}

func NewWebSocketClient

func NewWebSocketClient(options *options.LocalControllerOptions) ClientI

NewWebSocketClient creates client

type Message

type Message struct {
	Header  MessageHeader `json:"header"`
	Content []byte        `json:"content"`
}

Message defines message

type MessageHeader

type MessageHeader struct {
	Namespace    string `json:"namespace"`
	ResourceKind string `json:"resourceKind"`
	ResourceName string `json:"resourceName"`
	Operation    string `json:"operation"`
}

MessageHeader define header of message

type MessageResourceHandler

type MessageResourceHandler interface {
	GetName() string
	Insert(*Message) error
	Delete(*Message) error
}

type WSConnection

type WSConnection struct {
	WSConn *websocket.Conn
}

WSConnection defines conn