transport

Documentation

Index

• func NewClientTLSConfig(certPath, keyPath, caPath, serverName string) (*tls.Config, error)
• func NewRandomPrivateKey() ([]byte, 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 NewRandomPrivateKey

func NewRandomPrivateKey() ([]byte, 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 will dispatch message to related channel registered in Do function by its message type and laneKey.
	Dispatch(m msg.Message, laneKey string) bool
	// Same with Dispatch but with specified message type.
	DispatchWithType(m msg.Message, msgType, laneKey string) bool
}

func NewMessageTransporter

func NewMessageTransporter(sendCh chan msg.Message) MessageTransporter