Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Server ¶
type Server struct { eventstreamapi.UnimplementedEventStreamServer // contains filtered or unexported fields }
func NewServer ¶
func NewServer(queues queue.QueuePair, opts ...ServerOption) *Server
NewServer returns a new AppStream server instance with the given options
func (*Server) Push ¶
func (s *Server) Push(pushs eventstreamapi.EventStream_PushServer) error
Push implements a client-side stream to receive updates for the client's Application resources.
func (*Server) Subscribe ¶
func (s *Server) Subscribe(subs eventstreamapi.EventStream_SubscribeServer) error
Subscribe implements a bi-directional stream to exchange application updates between the agent and the server.
The connection is kept open until the agent closes it, and the stream tries to send updates to the agent as long as possible.
type ServerOption ¶
type ServerOption func(o *ServerOptions)
func WithMaxStreamDuration ¶
func WithMaxStreamDuration(d time.Duration) ServerOption
type ServerOptions ¶
Click to show internal directories.
Click to hide internal directories.