event_feed

package
v0.0.0-...-5a7b0e6 Latest Latest
Warning

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

 Go to latest Published: Dec 27, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package event_feed is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var File_interservice_event_feed_event_feed_proto protoreflect.FileDescriptor

Functions

func RegisterEventFeedServiceServer 

func RegisterEventFeedServiceServer(s *grpc.Server, srv EventFeedServiceServer)

Types

type ActionLine 

type ActionLine struct {
	Action string      `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty" toml:"action,omitempty" mapstructure:"action,omitempty"`
	Slots  []*Timeslot `protobuf:"bytes,2,rep,name=slots,proto3" json:"slots,omitempty" toml:"slots,omitempty" mapstructure:"slots,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionLine) Descriptor deprecated 

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

Deprecated: Use ActionLine.ProtoReflect.Descriptor instead.

func (*ActionLine) GetAction 

func (x *ActionLine) GetAction() string

func (*ActionLine) GetSlots 

func (x *ActionLine) GetSlots() []*Timeslot

func (*ActionLine) ProtoMessage 

func (*ActionLine) ProtoMessage()

func (*ActionLine) ProtoReflect 

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

func (*ActionLine) Reset 

func (x *ActionLine) Reset()

func (*ActionLine) String 

func (x *ActionLine) String() string

type Actor 

type Actor struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	ObjectType string `` /* 157-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) GetId 

func (x *Actor) GetId() string

func (*Actor) GetName 

func (x *Actor) GetName() 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 EntryCount 

type EntryCount struct {
	Category string `` /* 129-byte string literal not displayed */
	Count    int64  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty" toml:"count,omitempty" mapstructure:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*EntryCount) Descriptor deprecated 

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

Deprecated: Use EntryCount.ProtoReflect.Descriptor instead.

func (*EntryCount) GetCategory 

func (x *EntryCount) GetCategory() string

func (*EntryCount) GetCount 

func (x *EntryCount) GetCount() int64

func (*EntryCount) ProtoMessage 

func (*EntryCount) ProtoMessage()

func (*EntryCount) ProtoReflect 

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

func (*EntryCount) Reset 

func (x *EntryCount) Reset()

func (*EntryCount) String 

func (x *EntryCount) String() string

type EventExportRequest 

type EventExportRequest struct {

	// JSON or CSV
	OutputType string `` /* 157-byte string literal not displayed */
	// Filters to be applied to the request.
	Filter []string `protobuf:"bytes,2,rep,name=filter,proto3" json:"filter,omitempty" toml:"filter,omitempty" mapstructure:"filter,omitempty"`
	// Earliest events to return.
	Start int64 `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty" toml:"start,omitempty" mapstructure:"start,omitempty"`
	// Latest events to return.
	End int64 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty" toml:"end,omitempty" mapstructure:"end,omitempty"`
	// Order the results should be returned in.
	Order query.SortOrder `` /* 164-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*EventExportRequest) Descriptor deprecated 

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

Deprecated: Use EventExportRequest.ProtoReflect.Descriptor instead.

func (*EventExportRequest) GetEnd 

func (x *EventExportRequest) GetEnd() int64

func (*EventExportRequest) GetFilter 

func (x *EventExportRequest) GetFilter() []string

func (*EventExportRequest) GetOrder 

func (x *EventExportRequest) GetOrder() query.SortOrder

func (*EventExportRequest) GetOutputType 

func (x *EventExportRequest) GetOutputType() string

func (*EventExportRequest) GetStart 

func (x *EventExportRequest) GetStart() int64

func (*EventExportRequest) ProtoMessage 

func (*EventExportRequest) ProtoMessage()

func (*EventExportRequest) ProtoReflect 

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

func (*EventExportRequest) Reset 

func (x *EventExportRequest) Reset()

func (*EventExportRequest) String 

func (x *EventExportRequest) String() string

type EventExportResponse 

type EventExportResponse struct {

	// Exported reports in JSON or CSV.
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty" toml:"content,omitempty" mapstructure:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*EventExportResponse) Descriptor deprecated 

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

Deprecated: Use EventExportResponse.ProtoReflect.Descriptor instead.

func (*EventExportResponse) GetContent 

func (x *EventExportResponse) GetContent() []byte

func (*EventExportResponse) ProtoMessage 

func (*EventExportResponse) ProtoMessage()

func (*EventExportResponse) ProtoReflect 

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

func (*EventExportResponse) Reset 

func (x *EventExportResponse) Reset()

func (*EventExportResponse) String 

func (x *EventExportResponse) String() string

type EventFeedServiceClient 

type EventFeedServiceClient interface {
	GetFeed(ctx context.Context, in *FeedRequest, opts ...grpc.CallOption) (*FeedResponse, error)
	GetFeedSummary(ctx context.Context, in *FeedSummaryRequest, opts ...grpc.CallOption) (*FeedSummaryResponse, error)
	GetFeedTimeline(ctx context.Context, in *FeedTimelineRequest, opts ...grpc.CallOption) (*FeedTimelineResponse, error)
	HandleEvent(ctx context.Context, in *event.EventMsg, opts ...grpc.CallOption) (*event.EventResponse, error)
	EventExport(ctx context.Context, in *EventExportRequest, opts ...grpc.CallOption) (EventFeedService_EventExportClient, error)
}

EventFeedServiceClient is the client API for EventFeedService service.

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

func NewEventFeedServiceClient 

func NewEventFeedServiceClient(cc grpc.ClientConnInterface) EventFeedServiceClient

type EventFeedServiceServer 

type EventFeedServiceServer interface {
	GetFeed(context.Context, *FeedRequest) (*FeedResponse, error)
	GetFeedSummary(context.Context, *FeedSummaryRequest) (*FeedSummaryResponse, error)
	GetFeedTimeline(context.Context, *FeedTimelineRequest) (*FeedTimelineResponse, error)
	HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, error)
	EventExport(*EventExportRequest, EventFeedService_EventExportServer) error
}

EventFeedServiceServer is the server API for EventFeedService service.

type EventFeedService_EventExportClient 

type EventFeedService_EventExportClient interface {
	Recv() (*EventExportResponse, error)
	grpc.ClientStream
}

type EventFeedService_EventExportServer 

type EventFeedService_EventExportServer interface {
	Send(*EventExportResponse) error
	grpc.ServerStream
}

type FeedEntry 

type FeedEntry struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	EventType            string                 `` /* 152-byte string literal not displayed */
	FeedType             string                 `` /* 147-byte string literal not displayed */
	Tags                 []string               `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" toml:"tags,omitempty" mapstructure:"tags,omitempty"`
	SourceEventPublished *timestamppb.Timestamp `` /* 211-byte string literal not displayed */
	Created              *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty" toml:"created,omitempty" mapstructure:"created,omitempty"`
	Producer             *Producer              `` /* 129-byte string literal not displayed */
	Actor                *Actor                 `protobuf:"bytes,8,opt,name=actor,proto3" json:"actor,omitempty" toml:"actor,omitempty" mapstructure:"actor,omitempty"`
	Verb                 string                 `protobuf:"bytes,9,opt,name=verb,proto3" json:"verb,omitempty" toml:"verb,omitempty" mapstructure:"verb,omitempty"`
	Object               *Object                `protobuf:"bytes,10,opt,name=object,proto3" json:"object,omitempty" toml:"object,omitempty" mapstructure:"object,omitempty"`
	Target               *Target                `protobuf:"bytes,11,opt,name=target,proto3" json:"target,omitempty" toml:"target,omitempty" mapstructure:"target,omitempty"`
	Parent               *Parent                `protobuf:"bytes,12,opt,name=parent,proto3" json:"parent,omitempty" toml:"parent,omitempty" mapstructure:"parent,omitempty"`
	// Event's Chef Organization
	ChefOrganization string `` /* 188-byte string literal not displayed */
	// Event's Chef Infra Server
	ChefInfraServer string `` /* 187-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeedEntry) Descriptor deprecated 

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

Deprecated: Use FeedEntry.ProtoReflect.Descriptor instead.

func (*FeedEntry) GetActor 

func (x *FeedEntry) GetActor() *Actor

func (*FeedEntry) GetChefInfraServer 

func (x *FeedEntry) GetChefInfraServer() string

func (*FeedEntry) GetChefOrganization 

func (x *FeedEntry) GetChefOrganization() string

func (*FeedEntry) GetCreated 

func (x *FeedEntry) GetCreated() *timestamppb.Timestamp

func (*FeedEntry) GetEventType 

func (x *FeedEntry) GetEventType() string

func (*FeedEntry) GetFeedType 

func (x *FeedEntry) GetFeedType() string

func (*FeedEntry) GetId 

func (x *FeedEntry) GetId() string

func (*FeedEntry) GetObject 

func (x *FeedEntry) GetObject() *Object

func (*FeedEntry) GetParent 

func (x *FeedEntry) GetParent() *Parent

func (*FeedEntry) GetProducer 

func (x *FeedEntry) GetProducer() *Producer

func (*FeedEntry) GetSourceEventPublished 

func (x *FeedEntry) GetSourceEventPublished() *timestamppb.Timestamp

func (*FeedEntry) GetTags 

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

func (*FeedEntry) GetTarget 

func (x *FeedEntry) GetTarget() *Target

func (*FeedEntry) GetVerb 

func (x *FeedEntry) GetVerb() string

func (*FeedEntry) ProtoMessage 

func (*FeedEntry) ProtoMessage()

func (*FeedEntry) ProtoReflect 

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

func (*FeedEntry) Reset 

func (x *FeedEntry) Reset()

func (*FeedEntry) String 

func (x *FeedEntry) String() string

type FeedRequest 

type FeedRequest struct {
	UserId  string   `` /* 137-byte string literal not displayed */
	Size    int32    `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty" toml:"size,omitempty" mapstructure:"size,omitempty"`
	Start   int64    `protobuf:"varint,4,opt,name=start,proto3" json:"start,omitempty" toml:"start,omitempty" mapstructure:"start,omitempty"`
	End     int64    `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty" toml:"end,omitempty" mapstructure:"end,omitempty"`
	Before  int64    `protobuf:"varint,6,opt,name=before,proto3" json:"before,omitempty" toml:"before,omitempty" mapstructure:"before,omitempty"`
	After   int64    `protobuf:"varint,7,opt,name=after,proto3" json:"after,omitempty" toml:"after,omitempty" mapstructure:"after,omitempty"`
	Sort    []string `protobuf:"bytes,8,rep,name=sort,proto3" json:"sort,omitempty" toml:"sort,omitempty" mapstructure:"sort,omitempty"`
	Filters []string `protobuf:"bytes,9,rep,name=filters,proto3" json:"filters,omitempty" toml:"filters,omitempty" mapstructure:"filters,omitempty"`
	Cursor  string   `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty" toml:"cursor,omitempty" mapstructure:"cursor,omitempty"`
	// contains filtered or unexported fields
}

func (*FeedRequest) Descriptor deprecated 

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

Deprecated: Use FeedRequest.ProtoReflect.Descriptor instead.

func (*FeedRequest) GetAfter 

func (x *FeedRequest) GetAfter() int64

func (*FeedRequest) GetBefore 

func (x *FeedRequest) GetBefore() int64

func (*FeedRequest) GetCursor 

func (x *FeedRequest) GetCursor() string

func (*FeedRequest) GetEnd 

func (x *FeedRequest) GetEnd() int64

func (*FeedRequest) GetFilters 

func (x *FeedRequest) GetFilters() []string

func (*FeedRequest) GetSize 

func (x *FeedRequest) GetSize() int32

func (*FeedRequest) GetSort 

func (x *FeedRequest) GetSort() []string

func (*FeedRequest) GetStart 

func (x *FeedRequest) GetStart() int64

func (*FeedRequest) GetUserId 

func (x *FeedRequest) GetUserId() string

func (*FeedRequest) ProtoMessage 

func (*FeedRequest) ProtoMessage()

func (*FeedRequest) ProtoReflect 

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

func (*FeedRequest) Reset 

func (x *FeedRequest) Reset()

func (*FeedRequest) String 

func (x *FeedRequest) String() string

type FeedResponse 

type FeedResponse struct {
	FeedEntries  []*FeedEntry `` /* 162-byte string literal not displayed */
	TotalEntries int64        `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeedResponse) Descriptor deprecated 

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

Deprecated: Use FeedResponse.ProtoReflect.Descriptor instead.

func (*FeedResponse) GetFeedEntries 

func (x *FeedResponse) GetFeedEntries() []*FeedEntry

func (*FeedResponse) GetTotalEntries 

func (x *FeedResponse) GetTotalEntries() int64

func (*FeedResponse) ProtoMessage 

func (*FeedResponse) ProtoMessage()

func (*FeedResponse) ProtoReflect 

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

func (*FeedResponse) Reset 

func (x *FeedResponse) Reset()

func (*FeedResponse) String 

func (x *FeedResponse) String() string

type FeedSummaryRequest 

type FeedSummaryRequest struct {
	Start         int64    `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty" toml:"start,omitempty" mapstructure:"start,omitempty"`
	End           int64    `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty" toml:"end,omitempty" mapstructure:"end,omitempty"`
	Size          int32    `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty" toml:"size,omitempty" mapstructure:"size,omitempty"`
	From          int32    `protobuf:"varint,5,opt,name=from,proto3" json:"from,omitempty" toml:"from,omitempty" mapstructure:"from,omitempty"`
	StartAfter    string   `` /* 157-byte string literal not displayed */
	Filters       []string `protobuf:"bytes,7,rep,name=filters,proto3" json:"filters,omitempty" toml:"filters,omitempty" mapstructure:"filters,omitempty"`
	CountCategory string   `` /* 172-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeedSummaryRequest) Descriptor deprecated 

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

Deprecated: Use FeedSummaryRequest.ProtoReflect.Descriptor instead.

func (*FeedSummaryRequest) GetCountCategory 

func (x *FeedSummaryRequest) GetCountCategory() string

func (*FeedSummaryRequest) GetEnd 

func (x *FeedSummaryRequest) GetEnd() int64

func (*FeedSummaryRequest) GetFilters 

func (x *FeedSummaryRequest) GetFilters() []string

func (*FeedSummaryRequest) GetFrom 

func (x *FeedSummaryRequest) GetFrom() int32

func (*FeedSummaryRequest) GetSize 

func (x *FeedSummaryRequest) GetSize() int32

func (*FeedSummaryRequest) GetStart 

func (x *FeedSummaryRequest) GetStart() int64

func (*FeedSummaryRequest) GetStartAfter 

func (x *FeedSummaryRequest) GetStartAfter() string

func (*FeedSummaryRequest) ProtoMessage 

func (*FeedSummaryRequest) ProtoMessage()

func (*FeedSummaryRequest) ProtoReflect 

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

func (*FeedSummaryRequest) Reset 

func (x *FeedSummaryRequest) Reset()

func (*FeedSummaryRequest) String 

func (x *FeedSummaryRequest) String() string

type FeedSummaryResponse 

type FeedSummaryResponse struct {
	TotalEntries int64         `` /* 168-byte string literal not displayed */
	EntryCounts  []*EntryCount `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeedSummaryResponse) Descriptor deprecated 

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

Deprecated: Use FeedSummaryResponse.ProtoReflect.Descriptor instead.

func (*FeedSummaryResponse) GetEntryCounts 

func (x *FeedSummaryResponse) GetEntryCounts() []*EntryCount

func (*FeedSummaryResponse) GetTotalEntries 

func (x *FeedSummaryResponse) GetTotalEntries() int64

func (*FeedSummaryResponse) ProtoMessage 

func (*FeedSummaryResponse) ProtoMessage()

func (*FeedSummaryResponse) ProtoReflect 

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

func (*FeedSummaryResponse) Reset 

func (x *FeedSummaryResponse) Reset()

func (*FeedSummaryResponse) String 

func (x *FeedSummaryResponse) String() string

type FeedTimelineRequest 

type FeedTimelineRequest struct {
	Start    string   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty" toml:"start,omitempty" mapstructure:"start,omitempty"`
	End      string   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty" toml:"end,omitempty" mapstructure:"end,omitempty"`
	Timezone string   `` /* 129-byte string literal not displayed */
	Interval int32    `` /* 130-byte string literal not displayed */
	Filters  []string `protobuf:"bytes,5,rep,name=filters,proto3" json:"filters,omitempty" toml:"filters,omitempty" mapstructure:"filters,omitempty"`
	// contains filtered or unexported fields
}

func (*FeedTimelineRequest) Descriptor deprecated 

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

Deprecated: Use FeedTimelineRequest.ProtoReflect.Descriptor instead.

func (*FeedTimelineRequest) GetEnd 

func (x *FeedTimelineRequest) GetEnd() string

func (*FeedTimelineRequest) GetFilters 

func (x *FeedTimelineRequest) GetFilters() []string

func (*FeedTimelineRequest) GetInterval 

func (x *FeedTimelineRequest) GetInterval() int32

func (*FeedTimelineRequest) GetStart 

func (x *FeedTimelineRequest) GetStart() string

func (*FeedTimelineRequest) GetTimezone 

func (x *FeedTimelineRequest) GetTimezone() string

func (*FeedTimelineRequest) ProtoMessage 

func (*FeedTimelineRequest) ProtoMessage()

func (*FeedTimelineRequest) ProtoReflect 

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

func (*FeedTimelineRequest) Reset 

func (x *FeedTimelineRequest) Reset()

func (*FeedTimelineRequest) String 

func (x *FeedTimelineRequest) String() string

type FeedTimelineResponse 

type FeedTimelineResponse struct {
	Start       string        `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty" toml:"start,omitempty" mapstructure:"start,omitempty"`
	End         string        `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty" toml:"end,omitempty" mapstructure:"end,omitempty"`
	Interval    int32         `` /* 130-byte string literal not displayed */
	ActionLines []*ActionLine `` /* 162-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FeedTimelineResponse) Descriptor deprecated 

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

Deprecated: Use FeedTimelineResponse.ProtoReflect.Descriptor instead.

func (*FeedTimelineResponse) GetActionLines 

func (x *FeedTimelineResponse) GetActionLines() []*ActionLine

func (*FeedTimelineResponse) GetEnd 

func (x *FeedTimelineResponse) GetEnd() string

func (*FeedTimelineResponse) GetInterval 

func (x *FeedTimelineResponse) GetInterval() int32

func (*FeedTimelineResponse) GetStart 

func (x *FeedTimelineResponse) GetStart() string

func (*FeedTimelineResponse) ProtoMessage 

func (*FeedTimelineResponse) ProtoMessage()

func (*FeedTimelineResponse) ProtoReflect 

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

func (*FeedTimelineResponse) Reset 

func (x *FeedTimelineResponse) Reset()

func (*FeedTimelineResponse) String 

func (x *FeedTimelineResponse) String() string

type MockEventFeedServiceClient 

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

MockEventFeedServiceClient is a mock of EventFeedServiceClient interface.

func NewMockEventFeedServiceClient 

func NewMockEventFeedServiceClient(ctrl *gomock.Controller) *MockEventFeedServiceClient

NewMockEventFeedServiceClient creates a new mock instance.

func (*MockEventFeedServiceClient) EXPECT 

func (m *MockEventFeedServiceClient) EXPECT() *MockEventFeedServiceClientMockRecorder

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

func (*MockEventFeedServiceClient) EventExport 

func (m *MockEventFeedServiceClient) EventExport(arg0 context.Context, arg1 *EventExportRequest, arg2 ...grpc.CallOption) (EventFeedService_EventExportClient, error)

EventExport mocks base method.

func (*MockEventFeedServiceClient) GetFeed 

func (m *MockEventFeedServiceClient) GetFeed(arg0 context.Context, arg1 *FeedRequest, arg2 ...grpc.CallOption) (*FeedResponse, error)

GetFeed mocks base method.

func (*MockEventFeedServiceClient) GetFeedSummary 

func (m *MockEventFeedServiceClient) GetFeedSummary(arg0 context.Context, arg1 *FeedSummaryRequest, arg2 ...grpc.CallOption) (*FeedSummaryResponse, error)

GetFeedSummary mocks base method.

func (*MockEventFeedServiceClient) GetFeedTimeline 

func (m *MockEventFeedServiceClient) GetFeedTimeline(arg0 context.Context, arg1 *FeedTimelineRequest, arg2 ...grpc.CallOption) (*FeedTimelineResponse, error)

GetFeedTimeline mocks base method.

func (*MockEventFeedServiceClient) HandleEvent 

func (m *MockEventFeedServiceClient) HandleEvent(arg0 context.Context, arg1 *event.EventMsg, arg2 ...grpc.CallOption) (*event.EventResponse, error)

HandleEvent mocks base method.

type MockEventFeedServiceClientMockRecorder 

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

MockEventFeedServiceClientMockRecorder is the mock recorder for MockEventFeedServiceClient.

func (*MockEventFeedServiceClientMockRecorder) EventExport 

func (mr *MockEventFeedServiceClientMockRecorder) EventExport(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

EventExport indicates an expected call of EventExport.

func (*MockEventFeedServiceClientMockRecorder) GetFeed 

func (mr *MockEventFeedServiceClientMockRecorder) GetFeed(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetFeed indicates an expected call of GetFeed.

func (*MockEventFeedServiceClientMockRecorder) GetFeedSummary 

func (mr *MockEventFeedServiceClientMockRecorder) GetFeedSummary(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetFeedSummary indicates an expected call of GetFeedSummary.

func (*MockEventFeedServiceClientMockRecorder) GetFeedTimeline 

func (mr *MockEventFeedServiceClientMockRecorder) GetFeedTimeline(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetFeedTimeline indicates an expected call of GetFeedTimeline.

func (*MockEventFeedServiceClientMockRecorder) HandleEvent 

func (mr *MockEventFeedServiceClientMockRecorder) HandleEvent(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

HandleEvent indicates an expected call of HandleEvent.

type MockEventFeedServiceServer 

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

MockEventFeedServiceServer is a mock of EventFeedServiceServer interface.

func NewMockEventFeedServiceServer 

func NewMockEventFeedServiceServer(ctrl *gomock.Controller) *MockEventFeedServiceServer

NewMockEventFeedServiceServer creates a new mock instance.

func (*MockEventFeedServiceServer) EXPECT 

func (m *MockEventFeedServiceServer) EXPECT() *MockEventFeedServiceServerMockRecorder

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

func (*MockEventFeedServiceServer) EventExport 

func (m *MockEventFeedServiceServer) EventExport(arg0 *EventExportRequest, arg1 EventFeedService_EventExportServer) error

EventExport mocks base method.

func (*MockEventFeedServiceServer) GetFeed 

func (m *MockEventFeedServiceServer) GetFeed(arg0 context.Context, arg1 *FeedRequest) (*FeedResponse, error)

GetFeed mocks base method.

func (*MockEventFeedServiceServer) GetFeedSummary 

func (m *MockEventFeedServiceServer) GetFeedSummary(arg0 context.Context, arg1 *FeedSummaryRequest) (*FeedSummaryResponse, error)

GetFeedSummary mocks base method.

func (*MockEventFeedServiceServer) GetFeedTimeline 

func (m *MockEventFeedServiceServer) GetFeedTimeline(arg0 context.Context, arg1 *FeedTimelineRequest) (*FeedTimelineResponse, error)

GetFeedTimeline mocks base method.

func (*MockEventFeedServiceServer) HandleEvent 

func (m *MockEventFeedServiceServer) HandleEvent(arg0 context.Context, arg1 *event.EventMsg) (*event.EventResponse, error)

HandleEvent mocks base method.

type MockEventFeedServiceServerMockRecorder 

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

MockEventFeedServiceServerMockRecorder is the mock recorder for MockEventFeedServiceServer.

func (*MockEventFeedServiceServerMockRecorder) EventExport 

func (mr *MockEventFeedServiceServerMockRecorder) EventExport(arg0, arg1 interface{}) *gomock.Call

EventExport indicates an expected call of EventExport.

func (*MockEventFeedServiceServerMockRecorder) GetFeed 

func (mr *MockEventFeedServiceServerMockRecorder) GetFeed(arg0, arg1 interface{}) *gomock.Call

GetFeed indicates an expected call of GetFeed.

func (*MockEventFeedServiceServerMockRecorder) GetFeedSummary 

func (mr *MockEventFeedServiceServerMockRecorder) GetFeedSummary(arg0, arg1 interface{}) *gomock.Call

GetFeedSummary indicates an expected call of GetFeedSummary.

func (*MockEventFeedServiceServerMockRecorder) GetFeedTimeline 

func (mr *MockEventFeedServiceServerMockRecorder) GetFeedTimeline(arg0, arg1 interface{}) *gomock.Call

GetFeedTimeline indicates an expected call of GetFeedTimeline.

func (*MockEventFeedServiceServerMockRecorder) HandleEvent 

func (mr *MockEventFeedServiceServerMockRecorder) HandleEvent(arg0, arg1 interface{}) *gomock.Call

HandleEvent indicates an expected call of HandleEvent.

type MockEventFeedService_EventExportClient 

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

MockEventFeedService_EventExportClient is a mock of EventFeedService_EventExportClient interface.

func NewMockEventFeedService_EventExportClient 

func NewMockEventFeedService_EventExportClient(ctrl *gomock.Controller) *MockEventFeedService_EventExportClient

NewMockEventFeedService_EventExportClient creates a new mock instance.

func (*MockEventFeedService_EventExportClient) CloseSend 

func (m *MockEventFeedService_EventExportClient) CloseSend() error

CloseSend mocks base method.

func (*MockEventFeedService_EventExportClient) Context 

func (m *MockEventFeedService_EventExportClient) Context() context.Context

Context mocks base method.

func (*MockEventFeedService_EventExportClient) EXPECT 

func (m *MockEventFeedService_EventExportClient) EXPECT() *MockEventFeedService_EventExportClientMockRecorder

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

func (*MockEventFeedService_EventExportClient) Header 

func (m *MockEventFeedService_EventExportClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockEventFeedService_EventExportClient) Recv 

func (m *MockEventFeedService_EventExportClient) Recv() (*EventExportResponse, error)

Recv mocks base method.

func (*MockEventFeedService_EventExportClient) RecvMsg 

func (m *MockEventFeedService_EventExportClient) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockEventFeedService_EventExportClient) SendMsg 

func (m *MockEventFeedService_EventExportClient) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockEventFeedService_EventExportClient) Trailer 

func (m *MockEventFeedService_EventExportClient) Trailer() metadata.MD

Trailer mocks base method.

type MockEventFeedService_EventExportClientMockRecorder 

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

MockEventFeedService_EventExportClientMockRecorder is the mock recorder for MockEventFeedService_EventExportClient.

func (*MockEventFeedService_EventExportClientMockRecorder) CloseSend 

func (mr *MockEventFeedService_EventExportClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockEventFeedService_EventExportClientMockRecorder) Context 

func (mr *MockEventFeedService_EventExportClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockEventFeedService_EventExportClientMockRecorder) Header 

func (mr *MockEventFeedService_EventExportClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockEventFeedService_EventExportClientMockRecorder) Recv 

func (mr *MockEventFeedService_EventExportClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockEventFeedService_EventExportClientMockRecorder) RecvMsg 

func (mr *MockEventFeedService_EventExportClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockEventFeedService_EventExportClientMockRecorder) SendMsg 

func (mr *MockEventFeedService_EventExportClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockEventFeedService_EventExportClientMockRecorder) Trailer 

func (mr *MockEventFeedService_EventExportClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockEventFeedService_EventExportServer 

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

MockEventFeedService_EventExportServer is a mock of EventFeedService_EventExportServer interface.

func NewMockEventFeedService_EventExportServer 

func NewMockEventFeedService_EventExportServer(ctrl *gomock.Controller) *MockEventFeedService_EventExportServer

NewMockEventFeedService_EventExportServer creates a new mock instance.

func (*MockEventFeedService_EventExportServer) Context 

func (m *MockEventFeedService_EventExportServer) Context() context.Context

Context mocks base method.

func (*MockEventFeedService_EventExportServer) EXPECT 

func (m *MockEventFeedService_EventExportServer) EXPECT() *MockEventFeedService_EventExportServerMockRecorder

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

func (*MockEventFeedService_EventExportServer) RecvMsg 

func (m *MockEventFeedService_EventExportServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method.

func (*MockEventFeedService_EventExportServer) Send 

func (m *MockEventFeedService_EventExportServer) Send(arg0 *EventExportResponse) error

Send mocks base method.

func (*MockEventFeedService_EventExportServer) SendHeader 

func (m *MockEventFeedService_EventExportServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockEventFeedService_EventExportServer) SendMsg 

func (m *MockEventFeedService_EventExportServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method.

func (*MockEventFeedService_EventExportServer) SetHeader 

func (m *MockEventFeedService_EventExportServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockEventFeedService_EventExportServer) SetTrailer 

func (m *MockEventFeedService_EventExportServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockEventFeedService_EventExportServerMockRecorder 

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

MockEventFeedService_EventExportServerMockRecorder is the mock recorder for MockEventFeedService_EventExportServer.

func (*MockEventFeedService_EventExportServerMockRecorder) Context 

func (mr *MockEventFeedService_EventExportServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockEventFeedService_EventExportServerMockRecorder) RecvMsg 

func (mr *MockEventFeedService_EventExportServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockEventFeedService_EventExportServerMockRecorder) Send 

func (mr *MockEventFeedService_EventExportServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockEventFeedService_EventExportServerMockRecorder) SendHeader 

func (mr *MockEventFeedService_EventExportServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockEventFeedService_EventExportServerMockRecorder) SendMsg 

func (mr *MockEventFeedService_EventExportServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockEventFeedService_EventExportServerMockRecorder) SetHeader 

func (mr *MockEventFeedService_EventExportServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockEventFeedService_EventExportServerMockRecorder) SetTrailer 

func (mr *MockEventFeedService_EventExportServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type Object 

type Object struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	ObjectType string `` /* 157-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) GetId 

func (x *Object) GetId() string

func (*Object) GetName 

func (x *Object) GetName() 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 Parent 

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

func (*Parent) Descriptor deprecated 

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

Deprecated: Use Parent.ProtoReflect.Descriptor instead.

func (*Parent) GetId 

func (x *Parent) GetId() string

func (*Parent) GetName 

func (x *Parent) GetName() string

func (*Parent) ProtoMessage 

func (*Parent) ProtoMessage()

func (*Parent) ProtoReflect 

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

func (*Parent) Reset 

func (x *Parent) Reset()

func (*Parent) String 

func (x *Parent) 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"`
	Name       string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	ObjectType string   `` /* 157-byte string literal not displayed */
	PTags      []string `` /* 132-byte string literal not displayed */
	// 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) GetName 

func (x *Producer) GetName() string

func (*Producer) GetObjectType 

func (x *Producer) GetObjectType() string

func (*Producer) GetPTags 

func (x *Producer) GetPTags() []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 Target 

type Target struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" toml:"id,omitempty" mapstructure:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" toml:"name,omitempty" mapstructure:"name,omitempty"`
	ObjectType string `` /* 157-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) GetId 

func (x *Target) GetId() string

func (*Target) GetName 

func (x *Target) GetName() 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 Timeslot 

type Timeslot struct {
	Counts []*EntryCount `protobuf:"bytes,1,rep,name=counts,proto3" json:"counts,omitempty" toml:"counts,omitempty" mapstructure:"counts,omitempty"`
	// contains filtered or unexported fields
}

func (*Timeslot) Descriptor deprecated 

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

Deprecated: Use Timeslot.ProtoReflect.Descriptor instead.

func (*Timeslot) GetCounts 

func (x *Timeslot) GetCounts() []*EntryCount

func (*Timeslot) ProtoMessage 

func (*Timeslot) ProtoMessage()

func (*Timeslot) ProtoReflect 

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

func (*Timeslot) Reset 

func (x *Timeslot) Reset()

func (*Timeslot) String 

func (x *Timeslot) String() string

type UnimplementedEventFeedServiceServer 

type UnimplementedEventFeedServiceServer struct {
}

UnimplementedEventFeedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedEventFeedServiceServer) EventExport 

func (*UnimplementedEventFeedServiceServer) EventExport(*EventExportRequest, EventFeedService_EventExportServer) error

func (*UnimplementedEventFeedServiceServer) GetFeed 

func (*UnimplementedEventFeedServiceServer) GetFeed(context.Context, *FeedRequest) (*FeedResponse, error)

func (*UnimplementedEventFeedServiceServer) GetFeedSummary 

func (*UnimplementedEventFeedServiceServer) GetFeedSummary(context.Context, *FeedSummaryRequest) (*FeedSummaryResponse, error)

func (*UnimplementedEventFeedServiceServer) GetFeedTimeline 

func (*UnimplementedEventFeedServiceServer) GetFeedTimeline(context.Context, *FeedTimelineRequest) (*FeedTimelineResponse, error)

func (*UnimplementedEventFeedServiceServer) HandleEvent 

func (*UnimplementedEventFeedServiceServer) HandleEvent(context.Context, *event.EventMsg) (*event.EventResponse, 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.