eventmaster

package
v0.0.0 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2017 License: MIT Imports: 5 Imported by: 0

Documentation

Overview

Package eventmaster is a generated protocol buffer package.

It is generated from these files: 

eventmaster.proto

It has these top-level messages: 

Event
Query
TimeQuery
EventId
Topic
TopicResult
UpdateTopicRequest
DeleteTopicRequest
Dc
DcResult
UpdateDcRequest
WriteResponse
EmptyRequest
HealthcheckRequest
HealthcheckResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventMasterServer 

func RegisterEventMasterServer(s *grpc.Server, srv EventMasterServer)

Types

type Dc 

type Dc struct {
	Id     string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	DcName string `protobuf:"bytes,2,opt,name=dc_name,json=dcName" json:"dc_name,omitempty"`
}

func (*Dc) Descriptor 

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

func (*Dc) GetDcName 

func (m *Dc) GetDcName() string

func (*Dc) GetId 

func (m *Dc) GetId() string

func (*Dc) ProtoMessage 

func (*Dc) ProtoMessage()

func (*Dc) Reset 

func (m *Dc) Reset()

func (*Dc) String 

func (m *Dc) String() string

type DcResult 

type DcResult struct {
	Results []*Dc `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*DcResult) Descriptor 

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

func (*DcResult) GetResults 

func (m *DcResult) GetResults() []*Dc

func (*DcResult) ProtoMessage 

func (*DcResult) ProtoMessage()

func (*DcResult) Reset 

func (m *DcResult) Reset()

func (*DcResult) String 

func (m *DcResult) String() string

type DeleteTopicRequest 

type DeleteTopicRequest struct {
	TopicName string `protobuf:"bytes,1,opt,name=topic_name,json=topicName" json:"topic_name,omitempty"`
}

func (*DeleteTopicRequest) Descriptor 

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

func (*DeleteTopicRequest) GetTopicName 

func (m *DeleteTopicRequest) GetTopicName() string

func (*DeleteTopicRequest) ProtoMessage 

func (*DeleteTopicRequest) ProtoMessage()

func (*DeleteTopicRequest) Reset 

func (m *DeleteTopicRequest) Reset()

func (*DeleteTopicRequest) String 

func (m *DeleteTopicRequest) String() string

type EmptyRequest 

type EmptyRequest struct {
}

func (*EmptyRequest) Descriptor 

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

func (*EmptyRequest) ProtoMessage 

func (*EmptyRequest) ProtoMessage()

func (*EmptyRequest) Reset 

func (m *EmptyRequest) Reset()

func (*EmptyRequest) String 

func (m *EmptyRequest) String() string

type Event 

type Event struct {
	EventId       string   `protobuf:"bytes,1,opt,name=event_id,json=eventId" json:"event_id,omitempty"`
	ParentEventId string   `protobuf:"bytes,2,opt,name=parent_event_id,json=parentEventId" json:"parent_event_id,omitempty"`
	EventTime     int64    `protobuf:"varint,3,opt,name=event_time,json=eventTime" json:"event_time,omitempty"`
	Dc            string   `protobuf:"bytes,4,opt,name=dc" json:"dc,omitempty"`
	TopicName     string   `protobuf:"bytes,5,opt,name=topic_name,json=topicName" json:"topic_name,omitempty"`
	TagSet        []string `protobuf:"bytes,6,rep,name=tag_set,json=tagSet" json:"tag_set,omitempty"`
	Host          string   `protobuf:"bytes,7,opt,name=host" json:"host,omitempty"`
	TargetHostSet []string `protobuf:"bytes,8,rep,name=target_host_set,json=targetHostSet" json:"target_host_set,omitempty"`
	User          string   `protobuf:"bytes,9,opt,name=user" json:"user,omitempty"`
	Data          []byte   `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Event) Descriptor 

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

func (*Event) GetData 

func (m *Event) GetData() []byte

func (*Event) GetDc 

func (m *Event) GetDc() string

func (*Event) GetEventId 

func (m *Event) GetEventId() string

func (*Event) GetEventTime 

func (m *Event) GetEventTime() int64

func (*Event) GetHost 

func (m *Event) GetHost() string

func (*Event) GetParentEventId 

func (m *Event) GetParentEventId() string

func (*Event) GetTagSet 

func (m *Event) GetTagSet() []string

func (*Event) GetTargetHostSet 

func (m *Event) GetTargetHostSet() []string

func (*Event) GetTopicName 

func (m *Event) GetTopicName() string

func (*Event) GetUser 

func (m *Event) GetUser() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

type EventId 

type EventId struct {
	EventId string `protobuf:"bytes,1,opt,name=event_id,json=eventId" json:"event_id,omitempty"`
}

func (*EventId) Descriptor 

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

func (*EventId) GetEventId 

func (m *EventId) GetEventId() string

func (*EventId) ProtoMessage 

func (*EventId) ProtoMessage()

func (*EventId) Reset 

func (m *EventId) Reset()

func (*EventId) String 

func (m *EventId) String() string

type EventMasterClient 

type EventMasterClient interface {
	AddEvent(ctx context.Context, in *Event, opts ...grpc.CallOption) (*WriteResponse, error)
	GetEvents(ctx context.Context, in *Query, opts ...grpc.CallOption) (EventMaster_GetEventsClient, error)
	GetEventById(ctx context.Context, in *EventId, opts ...grpc.CallOption) (*Event, error)
	GetEventIds(ctx context.Context, in *TimeQuery, opts ...grpc.CallOption) (EventMaster_GetEventIdsClient, error)
	AddTopic(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*WriteResponse, error)
	UpdateTopic(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	DeleteTopic(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	GetTopics(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*TopicResult, error)
	AddDc(ctx context.Context, in *Dc, opts ...grpc.CallOption) (*WriteResponse, error)
	UpdateDc(ctx context.Context, in *UpdateDcRequest, opts ...grpc.CallOption) (*WriteResponse, error)
	GetDcs(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*DcResult, error)
	Healthcheck(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error)
}

func NewEventMasterClient 

func NewEventMasterClient(cc *grpc.ClientConn) EventMasterClient

type EventMasterServer 

type EventMasterServer interface {
	AddEvent(context.Context, *Event) (*WriteResponse, error)
	GetEvents(*Query, EventMaster_GetEventsServer) error
	GetEventById(context.Context, *EventId) (*Event, error)
	GetEventIds(*TimeQuery, EventMaster_GetEventIdsServer) error
	AddTopic(context.Context, *Topic) (*WriteResponse, error)
	UpdateTopic(context.Context, *UpdateTopicRequest) (*WriteResponse, error)
	DeleteTopic(context.Context, *DeleteTopicRequest) (*WriteResponse, error)
	GetTopics(context.Context, *EmptyRequest) (*TopicResult, error)
	AddDc(context.Context, *Dc) (*WriteResponse, error)
	UpdateDc(context.Context, *UpdateDcRequest) (*WriteResponse, error)
	GetDcs(context.Context, *EmptyRequest) (*DcResult, error)
	Healthcheck(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error)
}

type EventMaster_GetEventIdsClient 

type EventMaster_GetEventIdsClient interface {
	Recv() (*EventId, error)
	grpc.ClientStream
}

type EventMaster_GetEventIdsServer 

type EventMaster_GetEventIdsServer interface {
	Send(*EventId) error
	grpc.ServerStream
}

type EventMaster_GetEventsClient 

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

type EventMaster_GetEventsServer 

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

type HealthcheckRequest 

type HealthcheckRequest struct {
}

func (*HealthcheckRequest) Descriptor 

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

func (*HealthcheckRequest) ProtoMessage 

func (*HealthcheckRequest) ProtoMessage()

func (*HealthcheckRequest) Reset 

func (m *HealthcheckRequest) Reset()

func (*HealthcheckRequest) String 

func (m *HealthcheckRequest) String() string

type HealthcheckResponse 

type HealthcheckResponse struct {
	Response string `protobuf:"bytes,1,opt,name=response" json:"response,omitempty"`
}

func (*HealthcheckResponse) Descriptor 

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

func (*HealthcheckResponse) GetResponse 

func (m *HealthcheckResponse) GetResponse() string

func (*HealthcheckResponse) ProtoMessage 

func (*HealthcheckResponse) ProtoMessage()

func (*HealthcheckResponse) Reset 

func (m *HealthcheckResponse) Reset()

func (*HealthcheckResponse) String 

func (m *HealthcheckResponse) String() string

type Query 

type Query struct {
	Dc                    []string `protobuf:"bytes,1,rep,name=dc" json:"dc,omitempty"`
	Host                  []string `protobuf:"bytes,2,rep,name=host" json:"host,omitempty"`
	TargetHostSet         []string `protobuf:"bytes,3,rep,name=target_host_set,json=targetHostSet" json:"target_host_set,omitempty"`
	User                  []string `protobuf:"bytes,4,rep,name=user" json:"user,omitempty"`
	TopicName             []string `protobuf:"bytes,5,rep,name=topic_name,json=topicName" json:"topic_name,omitempty"`
	TagSet                []string `protobuf:"bytes,6,rep,name=tag_set,json=tagSet" json:"tag_set,omitempty"`
	ParentEventId         []string `protobuf:"bytes,7,rep,name=parent_event_id,json=parentEventId" json:"parent_event_id,omitempty"`
	Data                  string   `protobuf:"bytes,8,opt,name=data" json:"data,omitempty"`
	StartEventTime        int64    `protobuf:"varint,9,opt,name=start_event_time,json=startEventTime" json:"start_event_time,omitempty"`
	EndEventTime          int64    `protobuf:"varint,10,opt,name=end_event_time,json=endEventTime" json:"end_event_time,omitempty"`
	StartReceivedTime     int64    `protobuf:"varint,11,opt,name=start_received_time,json=startReceivedTime" json:"start_received_time,omitempty"`
	EndReceivedTime       int64    `protobuf:"varint,12,opt,name=end_received_time,json=endReceivedTime" json:"end_received_time,omitempty"`
	Start                 int32    `protobuf:"varint,15,opt,name=start" json:"start,omitempty"`
	Limit                 int32    `protobuf:"varint,16,opt,name=limit" json:"limit,omitempty"`
	EventId               string   `protobuf:"bytes,17,opt,name=event_id,json=eventId" json:"event_id,omitempty"`
	TagAndOperator        bool     `protobuf:"varint,18,opt,name=tag_and_operator,json=tagAndOperator" json:"tag_and_operator,omitempty"`
	TargetHostAndOperator bool     `protobuf:"varint,19,opt,name=target_host_and_operator,json=targetHostAndOperator" json:"target_host_and_operator,omitempty"`
	ExcludeTagSet         []string `protobuf:"bytes,20,rep,name=exclude_tag_set,json=excludeTagSet" json:"exclude_tag_set,omitempty"`
}

func (*Query) Descriptor 

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

func (*Query) GetData 

func (m *Query) GetData() string

func (*Query) GetDc 

func (m *Query) GetDc() []string

func (*Query) GetEndEventTime 

func (m *Query) GetEndEventTime() int64

func (*Query) GetEndReceivedTime 

func (m *Query) GetEndReceivedTime() int64

func (*Query) GetEventId 

func (m *Query) GetEventId() string

func (*Query) GetExcludeTagSet 

func (m *Query) GetExcludeTagSet() []string

func (*Query) GetHost 

func (m *Query) GetHost() []string

func (*Query) GetLimit 

func (m *Query) GetLimit() int32

func (*Query) GetParentEventId 

func (m *Query) GetParentEventId() []string

func (*Query) GetStart 

func (m *Query) GetStart() int32

func (*Query) GetStartEventTime 

func (m *Query) GetStartEventTime() int64

func (*Query) GetStartReceivedTime 

func (m *Query) GetStartReceivedTime() int64

func (*Query) GetTagAndOperator 

func (m *Query) GetTagAndOperator() bool

func (*Query) GetTagSet 

func (m *Query) GetTagSet() []string

func (*Query) GetTargetHostAndOperator 

func (m *Query) GetTargetHostAndOperator() bool

func (*Query) GetTargetHostSet 

func (m *Query) GetTargetHostSet() []string

func (*Query) GetTopicName 

func (m *Query) GetTopicName() []string

func (*Query) GetUser 

func (m *Query) GetUser() []string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

type TimeQuery 

type TimeQuery struct {
	StartEventTime int64 `protobuf:"varint,1,opt,name=start_event_time,json=startEventTime" json:"start_event_time,omitempty"`
	EndEventTime   int64 `protobuf:"varint,2,opt,name=end_event_time,json=endEventTime" json:"end_event_time,omitempty"`
	Limit          int32 `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
	Ascending      bool  `protobuf:"varint,4,opt,name=ascending" json:"ascending,omitempty"`
}

func (*TimeQuery) Descriptor 

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

func (*TimeQuery) GetAscending 

func (m *TimeQuery) GetAscending() bool

func (*TimeQuery) GetEndEventTime 

func (m *TimeQuery) GetEndEventTime() int64

func (*TimeQuery) GetLimit 

func (m *TimeQuery) GetLimit() int32

func (*TimeQuery) GetStartEventTime 

func (m *TimeQuery) GetStartEventTime() int64

func (*TimeQuery) ProtoMessage 

func (*TimeQuery) ProtoMessage()

func (*TimeQuery) Reset 

func (m *TimeQuery) Reset()

func (*TimeQuery) String 

func (m *TimeQuery) String() string

type Topic 

type Topic struct {
	Id         string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	TopicName  string `protobuf:"bytes,2,opt,name=topic_name,json=topicName" json:"topic_name,omitempty"`
	DataSchema []byte `protobuf:"bytes,3,opt,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"`
}

func (*Topic) Descriptor 

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

func (*Topic) GetDataSchema 

func (m *Topic) GetDataSchema() []byte

func (*Topic) GetId 

func (m *Topic) GetId() string

func (*Topic) GetTopicName 

func (m *Topic) GetTopicName() string

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) String 

func (m *Topic) String() string

type TopicResult 

type TopicResult struct {
	Results []*Topic `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*TopicResult) Descriptor 

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

func (*TopicResult) GetResults 

func (m *TopicResult) GetResults() []*Topic

func (*TopicResult) ProtoMessage 

func (*TopicResult) ProtoMessage()

func (*TopicResult) Reset 

func (m *TopicResult) Reset()

func (*TopicResult) String 

func (m *TopicResult) String() string

type UpdateDcRequest 

type UpdateDcRequest struct {
	OldName string `protobuf:"bytes,1,opt,name=old_name,json=oldName" json:"old_name,omitempty"`
	NewName string `protobuf:"bytes,2,opt,name=new_name,json=newName" json:"new_name,omitempty"`
}

func (*UpdateDcRequest) Descriptor 

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

func (*UpdateDcRequest) GetNewName 

func (m *UpdateDcRequest) GetNewName() string

func (*UpdateDcRequest) GetOldName 

func (m *UpdateDcRequest) GetOldName() string

func (*UpdateDcRequest) ProtoMessage 

func (*UpdateDcRequest) ProtoMessage()

func (*UpdateDcRequest) Reset 

func (m *UpdateDcRequest) Reset()

func (*UpdateDcRequest) String 

func (m *UpdateDcRequest) String() string

type UpdateTopicRequest 

type UpdateTopicRequest struct {
	OldName    string `protobuf:"bytes,1,opt,name=old_name,json=oldName" json:"old_name,omitempty"`
	NewName    string `protobuf:"bytes,2,opt,name=new_name,json=newName" json:"new_name,omitempty"`
	DataSchema []byte `protobuf:"bytes,3,opt,name=data_schema,json=dataSchema,proto3" json:"data_schema,omitempty"`
}

func (*UpdateTopicRequest) Descriptor 

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

func (*UpdateTopicRequest) GetDataSchema 

func (m *UpdateTopicRequest) GetDataSchema() []byte

func (*UpdateTopicRequest) GetNewName 

func (m *UpdateTopicRequest) GetNewName() string

func (*UpdateTopicRequest) GetOldName 

func (m *UpdateTopicRequest) GetOldName() string

func (*UpdateTopicRequest) ProtoMessage 

func (*UpdateTopicRequest) ProtoMessage()

func (*UpdateTopicRequest) Reset 

func (m *UpdateTopicRequest) Reset()

func (*UpdateTopicRequest) String 

func (m *UpdateTopicRequest) String() string

type WriteResponse 

type WriteResponse struct {
	Id string `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
}

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetId 

func (m *WriteResponse) GetId() string

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) String 

func (m *WriteResponse) String() string

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.
JackTT - Gopher 🇻🇳