proto

package
v0.38.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 19, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_proto_store_proto protoreflect.FileDescriptor

Functions

func RegisterStoreServer 

func RegisterStoreServer(s *grpc.Server, srv StoreServer)

Types

type Event 

type Event struct {
	Id               string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	AggregateId      string                 `protobuf:"bytes,2,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	AggregateVersion uint32                 `protobuf:"varint,3,opt,name=aggregate_version,json=aggregateVersion,proto3" json:"aggregate_version,omitempty"`
	AggregateKind    string                 `protobuf:"bytes,4,opt,name=aggregate_kind,json=aggregateKind,proto3" json:"aggregate_kind,omitempty"`
	Kind             string                 `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"`
	Body             []byte                 `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	IdempotencyKey   string                 `protobuf:"bytes,7,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	Metadata         map[string]string      `` /* 157-byte string literal not displayed */
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

func (*Event) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAggregateId 

func (x *Event) GetAggregateId() string

func (*Event) GetAggregateKind added in v0.28.0 

func (x *Event) GetAggregateKind() string

func (*Event) GetAggregateVersion 

func (x *Event) GetAggregateVersion() uint32

func (*Event) GetBody 

func (x *Event) GetBody() []byte

func (*Event) GetCreatedAt 

func (x *Event) GetCreatedAt() *timestamppb.Timestamp

func (*Event) GetId 

func (x *Event) GetId() string

func (*Event) GetIdempotencyKey 

func (x *Event) GetIdempotencyKey() string

func (*Event) GetKind 

func (x *Event) GetKind() string

func (*Event) GetMetadata 

func (x *Event) GetMetadata() map[string]string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Filter 

type Filter struct {
	AggregateKinds []string    `protobuf:"bytes,1,rep,name=aggregate_kinds,json=aggregateKinds,proto3" json:"aggregate_kinds,omitempty"`
	Metadata       []*Metadata `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Splits         uint32      `protobuf:"varint,3,opt,name=splits,proto3" json:"splits,omitempty"`
	SplitIds       []uint32    `protobuf:"varint,4,rep,packed,name=split_ids,json=splitIds,proto3" json:"split_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Filter) Descriptor deprecated 

func (*Filter) Descriptor() ([]byte, []int)

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetAggregateKinds added in v0.28.0 

func (x *Filter) GetAggregateKinds() []string

func (*Filter) GetMetadata 

func (x *Filter) GetMetadata() []*Metadata

func (*Filter) GetSplitIds added in v0.36.0 

func (x *Filter) GetSplitIds() []uint32

func (*Filter) GetSplits added in v0.34.0 

func (x *Filter) GetSplits() uint32

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

func (x *Filter) ProtoReflect() protoreflect.Message

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type GetEventsReply 

type GetEventsReply struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsReply) Descriptor deprecated 

func (*GetEventsReply) Descriptor() ([]byte, []int)

Deprecated: Use GetEventsReply.ProtoReflect.Descriptor instead.

func (*GetEventsReply) GetEvents 

func (x *GetEventsReply) GetEvents() []*Event

func (*GetEventsReply) ProtoMessage 

func (*GetEventsReply) ProtoMessage()

func (*GetEventsReply) ProtoReflect 

func (x *GetEventsReply) ProtoReflect() protoreflect.Message

func (*GetEventsReply) Reset 

func (x *GetEventsReply) Reset()

func (*GetEventsReply) String 

func (x *GetEventsReply) String() string

type GetEventsRequest 

type GetEventsRequest struct {
	AfterEventId string  `protobuf:"bytes,1,opt,name=after_event_id,json=afterEventId,proto3" json:"after_event_id,omitempty"`
	UntilEventId string  `protobuf:"bytes,2,opt,name=until_event_id,json=untilEventId,proto3" json:"until_event_id,omitempty"`
	Limit        int32   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Filter       *Filter `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEventsRequest) Descriptor deprecated 

func (*GetEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.

func (*GetEventsRequest) GetAfterEventId 

func (x *GetEventsRequest) GetAfterEventId() string

func (*GetEventsRequest) GetFilter 

func (x *GetEventsRequest) GetFilter() *Filter

func (*GetEventsRequest) GetLimit 

func (x *GetEventsRequest) GetLimit() int32

func (*GetEventsRequest) GetUntilEventId added in v0.34.0 

func (x *GetEventsRequest) GetUntilEventId() string

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) ProtoReflect 

func (x *GetEventsRequest) ProtoReflect() protoreflect.Message

func (*GetEventsRequest) Reset 

func (x *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (x *GetEventsRequest) String() string

type Metadata 

type Metadata struct {
	Key   string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated 

func (*Metadata) Descriptor() ([]byte, []int)

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetKey 

func (x *Metadata) GetKey() string

func (*Metadata) GetValue 

func (x *Metadata) GetValue() []string

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

func (x *Metadata) ProtoReflect() protoreflect.Message

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) String 

func (x *Metadata) String() string

type StoreClient 

type StoreClient interface {
	GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (*GetEventsReply, error)
}

StoreClient is the client API for Store service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStoreClient 

func NewStoreClient(cc grpc.ClientConnInterface) StoreClient

type StoreServer 

type StoreServer interface {
	GetEvents(context.Context, *GetEventsRequest) (*GetEventsReply, error)
}

StoreServer is the server API for Store service.

type UnimplementedStoreServer 

type UnimplementedStoreServer struct {
}

UnimplementedStoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedStoreServer) GetEvents 

func (*UnimplementedStoreServer) GetEvents(context.Context, *GetEventsRequest) (*GetEventsReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.