Documentation ¶
Overview ¶
Package grpcservice defines a service.Service which passes all received messages to a destination host using grpc.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GRPCService ¶
type GRPCService struct {
// contains filtered or unexported fields
}
GRPCService is a service.Service which forwards all received messages to an implementation of ggrpc.Processor.
func NewGRPCService ¶
func NewGRPCService(c *grpc.ClientConn) *GRPCService
NewGRPCService returns a service.Service which forwards received messages to c. Implementations which wish to implement transport security or otherwise control the connection used should define a service.Factory based on this.
func (*GRPCService) ProcessMessage ¶
func (*GRPCService) Stop ¶
func (s *GRPCService) Stop() error
func (*GRPCService) Update ¶
func (s *GRPCService) Update(c *grpc.ClientConn)
Update replaces the current connection with the given one, may be nil to indicate that a connection is currently unavailable.
Click to show internal directories.
Click to hide internal directories.