stream

Documentation

Index

• func New(srv iface.Service, ctx context.Context, config *structureSpec.Service, ...) (iface.Stream, error)
• type Command
  • func (c *Command) Send(ctx context.Context, body map[string]interface{}) (response.Response, error)
  • func (c *Command) SendTo(ctx context.Context, cid cid.Cid, body map[string]interface{}) (response.Response, error)
• type Stream
  • func (f *Stream) Application() string
  • func (s *Stream) Close()
  • func (st *Stream) Command(command string) (iface.Command, error)
  • func (f *Stream) Context() context.Context
  • func (f *Stream) Event() interface{}
  • func (st *Stream) HandleRaw(cmd *command.Command) (resp response.Response, err error)
  • func (st *Stream) Listen() (protocol string, err error)
  • func (f *Stream) Project() string
  • func (st *Stream) ProtocolHash() (protocol string, err error)
  • func (f *Stream) SmartOps() (uint32, error)
  • func (f *Stream) Type() uint32

Functions

func New

func New(srv iface.Service, ctx context.Context, config *structureSpec.Service, serviceApplication string, matcher *iface.MatchDefinition) (iface.Stream, error)

Types

type Command

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

func (*Command) Send

func (c *Command) Send(ctx context.Context, body map[string]interface{}) (response.Response, error)

func (*Command) SendTo

func (c *Command) SendTo(ctx context.Context, cid cid.Cid, body map[string]interface{}) (response.Response, error)

type Stream

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

func (*Stream) Application

func (f *Stream) Application() string

func (*Stream) Close

func (s *Stream) Close()

func (*Stream) Command

func (st *Stream) Command(command string) (iface.Command, error)

func (*Stream) Context

func (f *Stream) Context() context.Context

func (*Stream) Event

func (f *Stream) Event() interface{}

func (*Stream) HandleRaw

func (st *Stream) HandleRaw(cmd *command.Command) (resp response.Response, err error)

func (*Stream) Listen

func (st *Stream) Listen() (protocol string, err error)

func (*Stream) Project

func (f *Stream) Project() string

func (*Stream) ProtocolHash

func (st *Stream) ProtocolHash() (protocol string, err error)

func (*Stream) SmartOps

func (f *Stream) SmartOps() (uint32, error)

func (*Stream) Type

func (f *Stream) Type() uint32