tcp

Documentation

Index

• type BaseTCPClient
  • func NewBaseTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *BaseTCPClient
  • func (c *BaseTCPClient) Close()
  • func (c *BaseTCPClient) Goodbye()
  • func (c *BaseTCPClient) Heartbeat()
  • func (c *BaseTCPClient) Hello()
  • func (c *BaseTCPClient) IO(message tcp.Package, timeout int64) tcp.Package
  • func (c *BaseTCPClient) IsActive()
  • func (c *BaseTCPClient) Open()
  • func (c *BaseTCPClient) Reconnect()
  • func (c *BaseTCPClient) Send(message tcp.Package)
• type CloudEventTCPClient
  • func NewCloudEventTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPClient
  • func (c *CloudEventTCPClient) GetPubClient() EventMeshTCPPubClient
  • func (c *CloudEventTCPClient) GetSubClient() EventMeshTCPSubClient
  • func (c *CloudEventTCPClient) Init()
  • func (c *CloudEventTCPClient) Publish(message interface{}, timeout int64) gtcp.Package
• type CloudEventTCPPubClient
  • func NewCloudEventTCPPubClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPPubClient
• type CloudEventTCPSubClient
  • func NewCloudEventTCPSubClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPSubClient
• type EventMeshTCPClient
  • func CreateEventMeshTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig, ...) EventMeshTCPClient
• type EventMeshTCPPubClient
• type EventMeshTCPSubClient

Types

type BaseTCPClient

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

func NewBaseTCPClient

func NewBaseTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *BaseTCPClient

func (*BaseTCPClient) Close

func (c *BaseTCPClient) Close()

func (*BaseTCPClient) Goodbye

func (c *BaseTCPClient) Goodbye()

func (*BaseTCPClient) Heartbeat

func (c *BaseTCPClient) Heartbeat()

func (*BaseTCPClient) Hello

func (c *BaseTCPClient) Hello()

func (*BaseTCPClient) IO

func (c *BaseTCPClient) IO(message tcp.Package, timeout int64) tcp.Package

func (*BaseTCPClient) IsActive

func (c *BaseTCPClient) IsActive()

func (*BaseTCPClient) Open

func (c *BaseTCPClient) Open()

func (*BaseTCPClient) Reconnect

func (c *BaseTCPClient) Reconnect()

func (*BaseTCPClient) Send

func (c *BaseTCPClient) Send(message tcp.Package)

type CloudEventTCPClient

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

func NewCloudEventTCPClient

func NewCloudEventTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPClient

func (*CloudEventTCPClient) GetPubClient

func (c *CloudEventTCPClient) GetPubClient() EventMeshTCPPubClient

func (*CloudEventTCPClient) GetSubClient

func (c *CloudEventTCPClient) GetSubClient() EventMeshTCPSubClient

func (*CloudEventTCPClient) Init

func (c *CloudEventTCPClient) Init()

func (*CloudEventTCPClient) Publish

func (c *CloudEventTCPClient) Publish(message interface{}, timeout int64) gtcp.Package

type CloudEventTCPPubClient

type CloudEventTCPPubClient struct {
	*BaseTCPClient
}

func NewCloudEventTCPPubClient

func NewCloudEventTCPPubClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPPubClient

type CloudEventTCPSubClient

type CloudEventTCPSubClient struct {
	*BaseTCPClient
}

func NewCloudEventTCPSubClient

func NewCloudEventTCPSubClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig) *CloudEventTCPSubClient

type EventMeshTCPClient

type EventMeshTCPClient interface {
	Init()
	Publish(msg interface{}, timeout int64) gtcp.Package
	GetPubClient() EventMeshTCPPubClient
	GetSubClient() EventMeshTCPSubClient
}

func CreateEventMeshTCPClient

func CreateEventMeshTCPClient(eventMeshTcpClientConfig conf.EventMeshTCPClientConfig, messageType protocol.MessageType) EventMeshTCPClient

type EventMeshTCPPubClient

type EventMeshTCPPubClient interface {
	// contains filtered or unexported methods
}

type EventMeshTCPSubClient

type EventMeshTCPSubClient interface {
	// contains filtered or unexported methods
}