mucp

Documentation

Index

• func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error
• type SourceHandler
• type SourceService
  • func NewSourceService(name string, c client.Client) SourceService
• type Source_WatchService
• type Source_WatchStream

Functions

func RegisterSourceHandler

func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error

Types

type SourceHandler

type SourceHandler interface {
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Watch(context.Context, *WatchRequest, Source_WatchStream) error
}

type SourceService

type SourceService interface {
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Source_WatchService, error)
}

func NewSourceService

func NewSourceService(name string, c client.Client) SourceService

type Source_WatchService

type Source_WatchService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WatchResponse, error)
}

type Source_WatchStream

type Source_WatchStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchResponse) error
}