go_micro_srv_event_event

type CreateRequest struct {
	Record *go_micro_os_event.Record `protobuf:"bytes,1,opt,name=record" json:"record,omitempty"`
}

type CreateResponse struct {
}

type DeleteRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

type DeleteResponse struct {
}

type Event struct {
	EventHandler
}

type EventClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...client.CallOption) (*CreateResponse, error)
	Search(ctx context.Context, in *SearchRequest, opts ...client.CallOption) (*SearchResponse, error)
	Stream(ctx context.Context, in *StreamRequest, opts ...client.CallOption) (Event_StreamClient, error)
	// should not really be used since event sourcing is append only
	Update(ctx context.Context, in *UpdateRequest, opts ...client.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error)
}

type EventHandler interface {
	Read(context.Context, *ReadRequest, *ReadResponse) error
	Create(context.Context, *CreateRequest, *CreateResponse) error
	Search(context.Context, *SearchRequest, *SearchResponse) error
	Stream(context.Context, *StreamRequest, Event_StreamStream) error
	// should not really be used since event sourcing is append only
	Update(context.Context, *UpdateRequest, *UpdateResponse) error
	Delete(context.Context, *DeleteRequest, *DeleteResponse) error
}

type Event_StreamClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*StreamResponse, error)
}

type Event_StreamStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*StreamResponse) error
}

type ReadRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

type ReadResponse struct {
	Record *go_micro_os_event.Record `protobuf:"bytes,1,opt,name=record" json:"record,omitempty"`
}

type SearchRequest struct {
	// optional root_id
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// optional
	Type string `protobuf:"bytes,2,opt,name=type" json:"type,omitempty"`
	// timeseries bounds
	From int64 `protobuf:"varint,3,opt,name=from" json:"from,omitempty"`
	To   int64 `protobuf:"varint,4,opt,name=to" json:"to,omitempty"`
	// range bounds
	Limit  int64 `protobuf:"varint,5,opt,name=limit" json:"limit,omitempty"`
	Offset int64 `protobuf:"varint,6,opt,name=offset" json:"offset,omitempty"`
	// order
	Reverse bool `protobuf:"varint,7,opt,name=reverse" json:"reverse,omitempty"`
}

type SearchResponse struct {
	Records []*go_micro_os_event.Record `protobuf:"bytes,1,rep,name=records" json:"records,omitempty"`
}

type StreamRequest struct {
	// types to watch
	Types []string `protobuf:"bytes,1,rep,name=types" json:"types,omitempty"`
}

type StreamResponse struct {
	Record *go_micro_os_event.Record `protobuf:"bytes,1,opt,name=record" json:"record,omitempty"`
}

type UpdateRequest struct {
	Record *go_micro_os_event.Record `protobuf:"bytes,1,opt,name=record" json:"record,omitempty"`
}

type UpdateResponse struct {
}