rpc

Documentation

Index

• type CreateSnapshotViewReply
• type CreateSnapshotViewRequest
• type DeleteSnapshotViewReply
• type DeleteSnapshotViewRequest
• type Error
  • func NotFoundViewErr() *Error
• type ErrorReply
• type PullSnapshotViewReply
• type PullSnapshotViewRequest
• type RPC
  • func New(lifecycle fx.Lifecycle, config *configs.Config, l *zap.Logger, ...) *RPC
• type Route
  • func NewRoute(rpc *RPC, prefix string) *Route
  • func (r *Route) Handle(apiPath string, h func(*nats.Msg))

Types

type CreateSnapshotViewReply

type CreateSnapshotViewReply struct {
	ID         string    `json:"id"`
	Subscriber string    `json:"subscriber"`
	Collection string    `json:"collection"`
	CreatedAt  time.Time `json:"createAt"`
}

type CreateSnapshotViewRequest

type CreateSnapshotViewRequest struct {
	Subscriber string `json:"subscriber"`
	Collection string `json:"collection"`
}

type DeleteSnapshotViewReply

type DeleteSnapshotViewReply struct {
	ID string `json:"id"`
}

type DeleteSnapshotViewRequest

type DeleteSnapshotViewRequest struct {
	ID string `json:"id"`
}

type Error

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

func NotFoundViewErr

func NotFoundViewErr() *Error

type ErrorReply

type ErrorReply struct {
	Error *Error `json:"error"`
}

type PullSnapshotViewReply

type PullSnapshotViewReply struct {
	ID    string `json:"id"`
	Count int    `json:"count"`
}

type PullSnapshotViewRequest

type PullSnapshotViewRequest struct {
	ID           string `json:"id"`
	LastKey      string `json:"lastKey"`
	AfterLastKey bool   `json:"afterLastKey"`
}

type RPC

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

func New

func New(lifecycle fx.Lifecycle, config *configs.Config, l *zap.Logger, c *connector.Connector, s *snapshot.Snapshot, vm *view_manager.ViewManager) *RPC

type Route

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

func NewRoute

func NewRoute(rpc *RPC, prefix string) *Route

func (*Route) Handle

func (r *Route) Handle(apiPath string, h func(*nats.Msg))