grpc

Documentation

Index

• Constants
• type Connection
  • func NewConnection(identifier model.ClientIdentifier, stream OpenSergoTransportStream) *Connection
  • func (c *Connection) Identifier() model.ClientIdentifier
  • func (c *Connection) IsValid() bool
  • func (c *Connection) Stream() OpenSergoTransportStream
• type ConnectionManager
  • func NewConnectionManager() *ConnectionManager
  • func (c *ConnectionManager) Add(namespace, app, kind string, connection *Connection) error
  • func (c *ConnectionManager) Get(namespace, app, kind string) ([]*Connection, bool)
  • func (c *ConnectionManager) RemoveByIdentifier(identifier model.ClientIdentifier) error
• type ConnectionMap
• type OpenSergoTransportStream
• type Server
  • func NewServer(port uint32, subscribeHandlers []model.SubscribeRequestHandler) *Server
  • func (s *Server) ComponentName() string
  • func (s *Server) ConnectionManager() *ConnectionManager
  • func (s *Server) Run() error
• type TransportServer
  • func (s *TransportServer) SubscribeConfig(stream trpb.OpenSergoUniversalTransportService_SubscribeConfigServer) error

Constants

const (
	ACKFlag  = "ACK"
	NACKFlag = "NACK"

	Success              = 1
	CheckFormatError     = 4001
	ReqFormatError       = 4002
	RegisterWatcherError = 500
)

const (
	ClientIdentifierKey = "OpenSergoClientIdentifier"
)

Types

type Connection

type Connection struct {
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(identifier model.ClientIdentifier, stream OpenSergoTransportStream) *Connection

func (*Connection) Identifier

func (c *Connection) Identifier() model.ClientIdentifier

func (*Connection) IsValid

func (c *Connection) IsValid() bool

func (*Connection) Stream

func (c *Connection) Stream() OpenSergoTransportStream

type ConnectionManager

type ConnectionManager struct {
	// contains filtered or unexported fields
}

func NewConnectionManager

func NewConnectionManager() *ConnectionManager

func (*ConnectionManager) Add

func (c *ConnectionManager) Add(namespace, app, kind string, connection *Connection) error

func (*ConnectionManager) Get

func (c *ConnectionManager) Get(namespace, app, kind string) ([]*Connection, bool)

func (*ConnectionManager) RemoveByIdentifier

func (c *ConnectionManager) RemoveByIdentifier(identifier model.ClientIdentifier) error

type ConnectionMap

type ConnectionMap map[model.ClientIdentifier]*Connection

type OpenSergoTransportStream

type OpenSergoTransportStream = pb.OpenSergoUniversalTransportService_SubscribeConfigServer

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server represents the transport server of OpenSergo universal transport service (OUTS).

func NewServer

func NewServer(port uint32, subscribeHandlers []model.SubscribeRequestHandler) *Server

func (*Server) ComponentName

func (s *Server) ComponentName() string

func (*Server) ConnectionManager

func (s *Server) ConnectionManager() *ConnectionManager

func (*Server) Run

func (s *Server) Run() error

type TransportServer

type TransportServer struct {
	trpb.OpenSergoUniversalTransportServiceServer
	// contains filtered or unexported fields
}

TransportServer represents the gRPC server of OpenSergo universal transport service.

func (*TransportServer) SubscribeConfig

func (s *TransportServer) SubscribeConfig(stream trpb.OpenSergoUniversalTransportService_SubscribeConfigServer) error