transport

Documentation

Index

• func NewClientTLSConfig(certPath, keyPath, caPath, serverName string) (*tls.Config, error)
• func NewServerTLSConfig(certPath, keyPath, caPath string) (*tls.Config, error)
• type MessageTransporter
  • func NewMessageTransporter(sendCh chan msg.Message) MessageTransporter

Functions

func NewClientTLSConfig

func NewClientTLSConfig(certPath, keyPath, caPath, serverName string) (*tls.Config, error)

func NewServerTLSConfig

func NewServerTLSConfig(certPath, keyPath, caPath string) (*tls.Config, error)

Types

type MessageTransporter

type MessageTransporter interface {
	Send(msg.Message) error
	// Recv(ctx context.Context, laneKey string, msgType string) (Message, error)
	// Do will first send msg, then recv msg with the same laneKey and specified msgType.
	Do(ctx context.Context, req msg.Message, laneKey, recvMsgType string) (msg.Message, error)
	Dispatch(m msg.Message, laneKey string) bool
	DispatchWithType(m msg.Message, msgType, laneKey string) bool
}

func NewMessageTransporter

func NewMessageTransporter(sendCh chan msg.Message) MessageTransporter