transport

Jul 4, 2024

Changes in this version

+ 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 interface

+ Dispatch func(m msg.Message, laneKey string) bool

+ DispatchWithType func(m msg.Message, msgType, laneKey string) bool

+ Do func(ctx context.Context, req msg.Message, laneKey, recvMsgType string) (msg.Message, error)

+ Send func(msg.Message) error

+ func NewMessageTransporter(sendCh chan msg.Message) MessageTransporter