eventstream

Documentation

Index

• type Server
  • func NewServer(queues queue.QueuePair, opts ...ServerOption) *Server
  • func (s *Server) Push(pushs eventstreamapi.EventStream_PushServer) error
  • func (s *Server) Subscribe(subs eventstreamapi.EventStream_SubscribeServer) error
• type ServerOption
  • func WithMaxStreamDuration(d time.Duration) ServerOption
• type ServerOptions

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

type ServerOptions struct {
	MaxStreamDuration time.Duration
}