server

Documentation

Index

• type SessionOutput
• type SessionizedServer
  • func (s *SessionizedServer) CloseSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
  • func (s *SessionizedServer) Command(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
  • func (s *SessionizedServer) CommandStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error
  • func (s *SessionizedServer) Delete(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
  • func (s *SessionizedServer) KeepAliveSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
  • func (s *SessionizedServer) OpenSession(ctx context.Context, header *headers.RequestHeader, timeout *time.Duration) (*headers.ResponseHeader, error)
  • func (s *SessionizedServer) Query(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
  • func (s *SessionizedServer) QueryStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, ...) error
• type SimpleServer
  • func (s *SimpleServer) Command(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)
  • func (s *SimpleServer) Delete(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
  • func (s *SimpleServer) Open(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)
  • func (s *SimpleServer) Query(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

Types

type SessionOutput

type SessionOutput struct {
	streams.Result
	Header *headers.ResponseHeader
}

SessionOutput is a result for session-supporting servers containing session header information

type SessionizedServer

type SessionizedServer struct {
	Client node.Client
	Type   string
}

SessionizedServer is a base server for servers that support sessions

func (*SessionizedServer) CloseSession

func (s *SessionizedServer) CloseSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

CloseSession closes a session

func (*SessionizedServer) Command

func (s *SessionizedServer) Command(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

Command submits a command to the service

func (*SessionizedServer) CommandStream

func (s *SessionizedServer) CommandStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, stream streams.WriteStream) error

CommandStream submits a streaming command to the service

func (*SessionizedServer) Delete

func (s *SessionizedServer) Delete(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

Delete deletes the service

func (*SessionizedServer) KeepAliveSession

func (s *SessionizedServer) KeepAliveSession(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

KeepAliveSession keeps a session alive

func (*SessionizedServer) OpenSession

func (s *SessionizedServer) OpenSession(ctx context.Context, header *headers.RequestHeader, timeout *time.Duration) (*headers.ResponseHeader, error)

OpenSession opens a new session

func (*SessionizedServer) Query

func (s *SessionizedServer) Query(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

Query submits a query to the service

func (*SessionizedServer) QueryStream

func (s *SessionizedServer) QueryStream(ctx context.Context, name string, input []byte, header *headers.RequestHeader, stream streams.WriteStream) error

QueryStream submits a streaming query to the service

type SimpleServer

type SimpleServer struct {
	Client node.Client
	Type   string
}

SimpleServer is a base server for servers that do not support sessions

func (*SimpleServer) Command

func (s *SimpleServer) Command(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

Command submits a command to the service

func (*SimpleServer) Delete

func (s *SimpleServer) Delete(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

Delete deletes the service

func (*SimpleServer) Open

func (s *SimpleServer) Open(ctx context.Context, header *headers.RequestHeader) (*headers.ResponseHeader, error)

Open opens a simple session

func (*SimpleServer) Query

func (s *SimpleServer) Query(ctx context.Context, name string, input []byte, header *headers.RequestHeader) ([]byte, *headers.ResponseHeader, error)

Query submits a query to the service