peer

Documentation

Index

• func New(c config.ConnectionConfig, log *zap.Logger) (api.Peer, error)
• func NewFromGRPC(conn *grpc.ClientConn, log *zap.Logger, timeout time.Duration) (api.Peer, error)
• func NewProcessor(channelName string) api.PeerProcessor

Functions

func New

func New(c config.ConnectionConfig, log *zap.Logger) (api.Peer, error)

New returns new peer instance based on peer config

func NewFromGRPC

func NewFromGRPC(conn *grpc.ClientConn, log *zap.Logger, timeout time.Duration) (api.Peer, error)

NewFromGRPC allows initializing peer from existing GRPC connection

func NewProcessor

func NewProcessor(channelName string) api.PeerProcessor