event

package
v0.0.0-...-d1e9850 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 11 Imported by: 23

Documentation

Overview

Package event is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var File_interservice_event_event_proto protoreflect.FileDescriptor

Functions

func RegisterEventServiceServer 

func RegisterEventServiceServer(s *grpc.Server, srv EventServiceServer)

Types

type Actor 

type Actor struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	ObjectType  string `` /* 157-byte string literal not displayed */
	DisplayName string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Actor) Descriptor deprecated 

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

Deprecated: Use Actor.ProtoReflect.Descriptor instead.

func (*Actor) GetDisplayName 

func (x *Actor) GetDisplayName() string

func (*Actor) GetId 

func (x *Actor) GetId() string

func (*Actor) GetObjectType 

func (x *Actor) GetObjectType() string

func (*Actor) ProtoMessage 

func (*Actor) ProtoMessage()

func (*Actor) ProtoReflect 

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

func (*Actor) Reset 

func (x *Actor) Reset()

func (*Actor) String 

func (x *Actor) String() string

type EventMsg 

type EventMsg struct {
	EventId   string                 `` /* 142-byte string literal not displayed */
	Type      *EventType             `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty" toml:"type,omitempty" mapstructure:"type,omitempty"`
	Producer  *Producer              `` /* 129-byte string literal not displayed */
	Tags      []string               `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	Published *timestamppb.Timestamp `` /* 133-byte string literal not displayed */
	Actor     *Actor                 `protobuf:"bytes,6,opt,name=actor,proto3" json:"actor,omitempty" toml:"actor,omitempty" mapstructure:"actor,omitempty"`
	Verb      string                 `protobuf:"bytes,7,opt,name=verb,proto3" json:"verb,omitempty" toml:"verb,omitempty" mapstructure:"verb,omitempty"`
	Object    *Object                `protobuf:"bytes,8,opt,name=object,proto3" json:"object,omitempty" toml:"object,omitempty" mapstructure:"object,omitempty"`
	Target    *Target                `protobuf:"bytes,9,opt,name=target,proto3" json:"target,omitempty" toml:"target,omitempty" mapstructure:"target,omitempty"`
	Data      *structpb.Struct       `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty" toml:"data,omitempty" mapstructure:"data,omitempty"`
	Projects  []string               `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventMsg) Descriptor deprecated 

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

Deprecated: Use EventMsg.ProtoReflect.Descriptor instead.

func (*EventMsg) GetActor 

func (x *EventMsg) GetActor() *Actor

func (*EventMsg) GetData 

func (x *EventMsg) GetData() *structpb.Struct

func (*EventMsg) GetEventId 

func (x *EventMsg) GetEventId() string

func (*EventMsg) GetObject 

func (x *EventMsg) GetObject() *Object

func (*EventMsg) GetProducer 

func (x *EventMsg) GetProducer() *Producer

func (*EventMsg) GetProjects 

func (x *EventMsg) GetProjects() []string

func (*EventMsg) GetPublished 

func (x *EventMsg) GetPublished() *timestamppb.Timestamp

func (*EventMsg) GetTags 

func (x *EventMsg) GetTags() []string

func (*EventMsg) GetTarget 

func (x *EventMsg) GetTarget() *Target

func (*EventMsg) GetType 

func (x *EventMsg) GetType() *EventType

func (*EventMsg) GetVerb 

func (x *EventMsg) GetVerb() string

func (*EventMsg) ProtoMessage 

func (*EventMsg) ProtoMessage()

func (*EventMsg) ProtoReflect 

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

func (*EventMsg) Reset 

func (x *EventMsg) Reset()

func (*EventMsg) String 

func (x *EventMsg) String() string

type EventResponse 

type EventResponse struct {
	Success bool `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventResponse) Descriptor deprecated 

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

Deprecated: Use EventResponse.ProtoReflect.Descriptor instead.

func (*EventResponse) GetSuccess 

func (x *EventResponse) GetSuccess() bool

func (*EventResponse) ProtoMessage 

func (*EventResponse) ProtoMessage()

func (*EventResponse) ProtoReflect 

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

func (*EventResponse) Reset 

func (x *EventResponse) Reset()

func (*EventResponse) String 

func (x *EventResponse) String() string

type EventServiceClient 

type EventServiceClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

EventServiceClient is the client API for EventService service.

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

func NewEventServiceClient 

func NewEventServiceClient(cc grpc.ClientConnInterface) EventServiceClient

type EventServiceServer 

type EventServiceServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Start(context.Context, *StartRequest) (*StartResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
}

EventServiceServer is the server API for EventService service.

type EventType 

type EventType struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EventType) Descriptor deprecated 

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

Deprecated: Use EventType.ProtoReflect.Descriptor instead.

func (*EventType) GetName 

func (x *EventType) GetName() string

func (*EventType) ProtoMessage 

func (*EventType) ProtoMessage()

func (*EventType) ProtoReflect 

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

func (*EventType) Reset 

func (x *EventType) Reset()

func (*EventType) String 

func (x *EventType) String() string

type MockEventServiceClient 

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

MockEventServiceClient is a mock of EventServiceClient interface.

func NewMockEventServiceClient 

func NewMockEventServiceClient(ctrl *gomock.Controller) *MockEventServiceClient

NewMockEventServiceClient creates a new mock instance.

func (*MockEventServiceClient) EXPECT 

func (m *MockEventServiceClient) EXPECT() *MockEventServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventServiceClient) Publish 

func (m *MockEventServiceClient) Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

Publish mocks base method.

func (*MockEventServiceClient) Start 

func (m *MockEventServiceClient) Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StartResponse, error)

Start mocks base method.

func (*MockEventServiceClient) Stop 

func (m *MockEventServiceClient) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)

Stop mocks base method.

func (*MockEventServiceClient) Subscribe 

func (m *MockEventServiceClient) Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)

Subscribe mocks base method.

type MockEventServiceClientMockRecorder 

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

MockEventServiceClientMockRecorder is the mock recorder for MockEventServiceClient.

func (*MockEventServiceClientMockRecorder) Publish 

func (mr *MockEventServiceClientMockRecorder) Publish(ctx, in interface{}, opts ...interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockEventServiceClientMockRecorder) Start 

func (mr *MockEventServiceClientMockRecorder) Start(ctx, in interface{}, opts ...interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockEventServiceClientMockRecorder) Stop 

func (mr *MockEventServiceClientMockRecorder) Stop(ctx, in interface{}, opts ...interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockEventServiceClientMockRecorder) Subscribe 

func (mr *MockEventServiceClientMockRecorder) Subscribe(ctx, in interface{}, opts ...interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type MockEventServiceServer 

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

MockEventServiceServer is a mock of EventServiceServer interface.

func NewMockEventServiceServer 

func NewMockEventServiceServer(ctrl *gomock.Controller) *MockEventServiceServer

NewMockEventServiceServer creates a new mock instance.

func (*MockEventServiceServer) EXPECT 

func (m *MockEventServiceServer) EXPECT() *MockEventServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEventServiceServer) Publish 

func (m *MockEventServiceServer) Publish(arg0 context.Context, arg1 *PublishRequest) (*PublishResponse, error)

Publish mocks base method.

func (*MockEventServiceServer) Start 

func (m *MockEventServiceServer) Start(arg0 context.Context, arg1 *StartRequest) (*StartResponse, error)

Start mocks base method.

func (*MockEventServiceServer) Stop 

func (m *MockEventServiceServer) Stop(arg0 context.Context, arg1 *StopRequest) (*StopResponse, error)

Stop mocks base method.

func (*MockEventServiceServer) Subscribe 

func (m *MockEventServiceServer) Subscribe(arg0 context.Context, arg1 *SubscribeRequest) (*SubscribeResponse, error)

Subscribe mocks base method.

type MockEventServiceServerMockRecorder 

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

MockEventServiceServerMockRecorder is the mock recorder for MockEventServiceServer.

func (*MockEventServiceServerMockRecorder) Publish 

func (mr *MockEventServiceServerMockRecorder) Publish(arg0, arg1 interface{}) *gomock.Call

Publish indicates an expected call of Publish.

func (*MockEventServiceServerMockRecorder) Start 

func (mr *MockEventServiceServerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockEventServiceServerMockRecorder) Stop 

func (mr *MockEventServiceServerMockRecorder) Stop(arg0, arg1 interface{}) *gomock.Call

Stop indicates an expected call of Stop.

func (*MockEventServiceServerMockRecorder) Subscribe 

func (mr *MockEventServiceServerMockRecorder) Subscribe(arg0, arg1 interface{}) *gomock.Call

Subscribe indicates an expected call of Subscribe.

type Object 

type Object struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	ObjectType  string `` /* 157-byte string literal not displayed */
	DisplayName string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Object) Descriptor deprecated 

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

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) GetDisplayName 

func (x *Object) GetDisplayName() string

func (*Object) GetId 

func (x *Object) GetId() string

func (*Object) GetObjectType 

func (x *Object) GetObjectType() string

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) ProtoReflect 

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

func (*Object) Reset 

func (x *Object) Reset()

func (*Object) String 

func (x *Object) String() string

type Producer 

type Producer struct {
	Id           string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	ProducerName string   `` /* 167-byte string literal not displayed */
	ProducerType string   `` /* 167-byte string literal not displayed */
	Tags         []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Producer) Descriptor deprecated 

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

Deprecated: Use Producer.ProtoReflect.Descriptor instead.

func (*Producer) GetId 

func (x *Producer) GetId() string

func (*Producer) GetProducerName 

func (x *Producer) GetProducerName() string

func (*Producer) GetProducerType 

func (x *Producer) GetProducerType() string

func (*Producer) GetTags 

func (x *Producer) GetTags() []string

func (*Producer) ProtoMessage 

func (*Producer) ProtoMessage()

func (*Producer) ProtoReflect 

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

func (*Producer) Reset 

func (x *Producer) Reset()

func (*Producer) String 

func (x *Producer) String() string

type PublishRequest 

type PublishRequest struct {
	Msg *EventMsg `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty" toml:"msg,omitempty" mapstructure:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetMsg 

func (x *PublishRequest) GetMsg() *EventMsg

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishResponse 

type PublishResponse struct {
	Success bool `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetSuccess 

func (x *PublishResponse) GetSuccess() bool

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type StartRequest 

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

func (*StartRequest) Descriptor deprecated 

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

Deprecated: Use StartRequest.ProtoReflect.Descriptor instead.

func (*StartRequest) ProtoMessage 

func (*StartRequest) ProtoMessage()

func (*StartRequest) ProtoReflect 

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

func (*StartRequest) Reset 

func (x *StartRequest) Reset()

func (*StartRequest) String 

func (x *StartRequest) String() string

type StartResponse 

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

func (*StartResponse) Descriptor deprecated 

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

Deprecated: Use StartResponse.ProtoReflect.Descriptor instead.

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) ProtoReflect 

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

func (*StartResponse) Reset 

func (x *StartResponse) Reset()

func (*StartResponse) String 

func (x *StartResponse) String() string

type StopRequest 

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

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

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

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

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

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

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

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type SubscribeRequest 

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

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

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

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type Target 

type Target struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	ObjectType  string `` /* 157-byte string literal not displayed */
	DisplayName string `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Target) Descriptor deprecated 

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetDisplayName 

func (x *Target) GetDisplayName() string

func (*Target) GetId 

func (x *Target) GetId() string

func (*Target) GetObjectType 

func (x *Target) GetObjectType() string

func (*Target) ProtoMessage 

func (*Target) ProtoMessage()

func (*Target) ProtoReflect 

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

type UnimplementedEventServiceServer 

type UnimplementedEventServiceServer struct {
}

UnimplementedEventServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventServiceServer) Publish 

func (*UnimplementedEventServiceServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (*UnimplementedEventServiceServer) Start 

func (*UnimplementedEventServiceServer) Start(context.Context, *StartRequest) (*StartResponse, error)

func (*UnimplementedEventServiceServer) Stop 

func (*UnimplementedEventServiceServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

func (*UnimplementedEventServiceServer) Subscribe 

func (*UnimplementedEventServiceServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, 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.