gen

package
v0.0.18 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_command_proto protoreflect.FileDescriptor
View Source 
var File_event_proto protoreflect.FileDescriptor
View Source 
var File_query_proto protoreflect.FileDescriptor
View Source 
var File_ref_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CommandEnvelope 

type CommandEnvelope struct {
	CommandId     string                 `protobuf:"bytes,1,opt,name=command_id,json=commandId,proto3" json:"command_id,omitempty"`
	CorrelationId string                 `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	UserId        string                 `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Aggregate     string                 `protobuf:"bytes,5,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	AggregateId   string                 `protobuf:"bytes,6,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	CommandType   string                 `protobuf:"bytes,7,opt,name=command_type,json=commandType,proto3" json:"command_type,omitempty"`
	Payload       []byte                 `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata      map[string]string      `` /* 143-byte string literal not displayed */
	ExtraMetadata *structpb.Struct       `protobuf:"bytes,10,opt,name=extra_metadata,json=extraMetadata,proto3" json:"extra_metadata,omitempty"`
	TenantId      string                 `protobuf:"bytes,11,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Parents       []*ParentRef           `protobuf:"bytes,12,rep,name=parents,proto3" json:"parents,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandEnvelope) Descriptor deprecated 

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

Deprecated: Use CommandEnvelope.ProtoReflect.Descriptor instead.

func (*CommandEnvelope) GetAggregate 

func (x *CommandEnvelope) GetAggregate() string

func (*CommandEnvelope) GetAggregateId 

func (x *CommandEnvelope) GetAggregateId() string

func (*CommandEnvelope) GetCommandId 

func (x *CommandEnvelope) GetCommandId() string

func (*CommandEnvelope) GetCommandType 

func (x *CommandEnvelope) GetCommandType() string

func (*CommandEnvelope) GetCorrelationId 

func (x *CommandEnvelope) GetCorrelationId() string

func (*CommandEnvelope) GetExtraMetadata 

func (x *CommandEnvelope) GetExtraMetadata() *structpb.Struct

func (*CommandEnvelope) GetMetadata 

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

func (*CommandEnvelope) GetParents added in v0.0.14 

func (x *CommandEnvelope) GetParents() []*ParentRef

func (*CommandEnvelope) GetPayload 

func (x *CommandEnvelope) GetPayload() []byte

func (*CommandEnvelope) GetTenantId 

func (x *CommandEnvelope) GetTenantId() string

func (*CommandEnvelope) GetTimestamp 

func (x *CommandEnvelope) GetTimestamp() *timestamppb.Timestamp

func (*CommandEnvelope) GetUserId 

func (x *CommandEnvelope) GetUserId() string

func (*CommandEnvelope) ProtoMessage 

func (*CommandEnvelope) ProtoMessage()

func (*CommandEnvelope) ProtoReflect 

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

func (*CommandEnvelope) Reset 

func (x *CommandEnvelope) Reset()

func (*CommandEnvelope) String 

func (x *CommandEnvelope) String() string

type EventEnvelope 

type EventEnvelope struct {
	EventId       string                 `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	CorrelationId string                 `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	Timestamp     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	AggregateType string                 `protobuf:"bytes,4,opt,name=aggregate_type,json=aggregateType,proto3" json:"aggregate_type,omitempty"`
	AggregateId   string                 `protobuf:"bytes,5,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	EventType     string                 `protobuf:"bytes,6,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Payload       []byte                 `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	UserId        string                 `protobuf:"bytes,8,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Metadata      map[string]string      `` /* 143-byte string literal not displayed */
	ExtraMetadata *structpb.Struct       `protobuf:"bytes,10,opt,name=extra_metadata,json=extraMetadata,proto3" json:"extra_metadata,omitempty"`
	TenantId      string                 `protobuf:"bytes,11,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Parents       []*ParentRef           `protobuf:"bytes,12,rep,name=parents,proto3" json:"parents,omitempty"`
	// contains filtered or unexported fields
}

func (*EventEnvelope) Descriptor deprecated 

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

Deprecated: Use EventEnvelope.ProtoReflect.Descriptor instead.

func (*EventEnvelope) GetAggregateId 

func (x *EventEnvelope) GetAggregateId() string

func (*EventEnvelope) GetAggregateType 

func (x *EventEnvelope) GetAggregateType() string

func (*EventEnvelope) GetCorrelationId 

func (x *EventEnvelope) GetCorrelationId() string

func (*EventEnvelope) GetEventId 

func (x *EventEnvelope) GetEventId() string

func (*EventEnvelope) GetEventType 

func (x *EventEnvelope) GetEventType() string

func (*EventEnvelope) GetExtraMetadata 

func (x *EventEnvelope) GetExtraMetadata() *structpb.Struct

func (*EventEnvelope) GetMetadata 

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

func (*EventEnvelope) GetParents added in v0.0.2 

func (x *EventEnvelope) GetParents() []*ParentRef

func (*EventEnvelope) GetPayload 

func (x *EventEnvelope) GetPayload() []byte

func (*EventEnvelope) GetTenantId 

func (x *EventEnvelope) GetTenantId() string

func (*EventEnvelope) GetTimestamp 

func (x *EventEnvelope) GetTimestamp() *timestamppb.Timestamp

func (*EventEnvelope) GetUserId 

func (x *EventEnvelope) GetUserId() string

func (*EventEnvelope) ProtoMessage 

func (*EventEnvelope) ProtoMessage()

func (*EventEnvelope) ProtoReflect 

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

func (*EventEnvelope) Reset 

func (x *EventEnvelope) Reset()

func (*EventEnvelope) String 

func (x *EventEnvelope) String() string

type ParentRef added in v0.0.2 

type ParentRef struct {
	AggregateType string `protobuf:"bytes,1,opt,name=aggregate_type,json=aggregateType,proto3" json:"aggregate_type,omitempty"`
	AggregateId   string `protobuf:"bytes,2,opt,name=aggregate_id,json=aggregateId,proto3" json:"aggregate_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentRef) Descriptor deprecated added in v0.0.2 

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

Deprecated: Use ParentRef.ProtoReflect.Descriptor instead.

func (*ParentRef) GetAggregateId added in v0.0.2 

func (x *ParentRef) GetAggregateId() string

func (*ParentRef) GetAggregateType added in v0.0.2 

func (x *ParentRef) GetAggregateType() string

func (*ParentRef) ProtoMessage added in v0.0.2 

func (*ParentRef) ProtoMessage()

func (*ParentRef) ProtoReflect added in v0.0.2 

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

func (*ParentRef) Reset added in v0.0.2 

func (x *ParentRef) Reset()

func (*ParentRef) String added in v0.0.2 

func (x *ParentRef) String() string

type QueryEnvelope 

type QueryEnvelope struct {
	QueryType     string           `protobuf:"bytes,1,opt,name=query_type,json=queryType,proto3" json:"query_type,omitempty"`
	Payload       []byte           `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	ExtraMetadata *structpb.Struct `protobuf:"bytes,3,opt,name=extra_metadata,json=extraMetadata,proto3" json:"extra_metadata,omitempty"`
	TenantId      string           `protobuf:"bytes,4,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	CorrelationId string           `protobuf:"bytes,5,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	UserId        string           `protobuf:"bytes,6,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryEnvelope) Descriptor deprecated 

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

Deprecated: Use QueryEnvelope.ProtoReflect.Descriptor instead.

func (*QueryEnvelope) GetCorrelationId 

func (x *QueryEnvelope) GetCorrelationId() string

func (*QueryEnvelope) GetExtraMetadata 

func (x *QueryEnvelope) GetExtraMetadata() *structpb.Struct

func (*QueryEnvelope) GetPayload 

func (x *QueryEnvelope) GetPayload() []byte

func (*QueryEnvelope) GetQueryType 

func (x *QueryEnvelope) GetQueryType() string

func (*QueryEnvelope) GetTenantId 

func (x *QueryEnvelope) GetTenantId() string

func (*QueryEnvelope) GetUserId 

func (x *QueryEnvelope) GetUserId() string

func (*QueryEnvelope) ProtoMessage 

func (*QueryEnvelope) ProtoMessage()

func (*QueryEnvelope) ProtoReflect 

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

func (*QueryEnvelope) Reset 

func (x *QueryEnvelope) Reset()

func (*QueryEnvelope) String 

func (x *QueryEnvelope) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.