es

type Ack struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Aggregate struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Schema               string            `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	Version              int64             `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Format               Aggregate_Format  `protobuf:"varint,4,opt,name=format,proto3,enum=es.Aggregate_Format" json:"format,omitempty"`
	Data                 []byte            `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	Metadata             map[string]string `` /* 157-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

type Aggregate_Format int32

type Event struct {
	// Topic (name) of the event. These should be written in the past tense (snap_created)
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Aggregate to which the event refers to.
	Aggregate *Aggregate `protobuf:"bytes,2,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	// Priority of the event, where 0 is the highest priority.
	Priority int32 `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	// Signature includes SHA1 signature computed against it's contents and signature of the previous event.
	Signature string `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// Origin of the event. e.g. service name.
	OriginName string `protobuf:"bytes,5,opt,name=origin_name,json=originName,proto3" json:"origin_name,omitempty"`
	// Origin of the event. e.g. service ip address / browser.
	OriginIp string `protobuf:"bytes,6,opt,name=origin_ip,json=originIp,proto3" json:"origin_ip,omitempty"`
	// Metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Created has the identification of which service has created the event and
	// respective timestamp at which the event ocurred
	Created              *timestamp.Timestamp `protobuf:"bytes,8,opt,name=created,proto3" json:"created,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

type EventSourceCommandClient interface {
	Create(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Ack, error)
	Snap(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Ack, error)
}

type EventSourceCommandServer interface {
	Create(context.Context, *Event) (*Ack, error)
	Snap(context.Context, *Event) (*Ack, error)
}

type EventSourceProjectionClient interface {
	Get(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Event, error)
	List(ctx context.Context, in *Query, opts ...grpc.CallOption) (EventSourceProjection_ListClient, error)
}

type EventSourceProjectionServer interface {
	Get(context.Context, *Event) (*Event, error)
	List(*Query, EventSourceProjection_ListServer) error
}

type EventSourceProjection_ListClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventSourceProjection_ListServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Query struct {
	Params               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}