Versions in this module Expand all Collapse all v0 v0.0.0 Aug 25, 2017 Changes in this version + func RegisterEventMasterServer(s *grpc.Server, srv EventMasterServer) + type Dc struct + DcName string + Id string + func (*Dc) Descriptor() ([]byte, []int) + func (*Dc) ProtoMessage() + func (m *Dc) GetDcName() string + func (m *Dc) GetId() string + func (m *Dc) Reset() + func (m *Dc) String() string + type DcResult struct + Results []*Dc + func (*DcResult) Descriptor() ([]byte, []int) + func (*DcResult) ProtoMessage() + func (m *DcResult) GetResults() []*Dc + func (m *DcResult) Reset() + func (m *DcResult) String() string + type DeleteTopicRequest struct + TopicName string + func (*DeleteTopicRequest) Descriptor() ([]byte, []int) + func (*DeleteTopicRequest) ProtoMessage() + func (m *DeleteTopicRequest) GetTopicName() string + func (m *DeleteTopicRequest) Reset() + func (m *DeleteTopicRequest) String() string + type EmptyRequest struct + func (*EmptyRequest) Descriptor() ([]byte, []int) + func (*EmptyRequest) ProtoMessage() + func (m *EmptyRequest) Reset() + func (m *EmptyRequest) String() string + type Event struct + Data []byte + Dc string + EventId string + EventTime int64 + Host string + ParentEventId string + TagSet []string + TargetHostSet []string + TopicName string + User string + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetData() []byte + func (m *Event) GetDc() string + func (m *Event) GetEventId() string + func (m *Event) GetEventTime() int64 + func (m *Event) GetHost() string + func (m *Event) GetParentEventId() string + func (m *Event) GetTagSet() []string + func (m *Event) GetTargetHostSet() []string + func (m *Event) GetTopicName() string + func (m *Event) GetUser() string + func (m *Event) Reset() + func (m *Event) String() string + type EventId struct + EventId string + func (*EventId) Descriptor() ([]byte, []int) + func (*EventId) ProtoMessage() + func (m *EventId) GetEventId() string + func (m *EventId) Reset() + func (m *EventId) String() string + type EventMasterClient interface + AddDc func(ctx context.Context, in *Dc, opts ...grpc.CallOption) (*WriteResponse, error) + AddEvent func(ctx context.Context, in *Event, opts ...grpc.CallOption) (*WriteResponse, error) + AddTopic func(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*WriteResponse, error) + DeleteTopic func(ctx context.Context, in *DeleteTopicRequest, opts ...grpc.CallOption) (*WriteResponse, error) + GetDcs func(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*DcResult, error) + GetEventById func(ctx context.Context, in *EventId, opts ...grpc.CallOption) (*Event, error) + GetEventIds func(ctx context.Context, in *TimeQuery, opts ...grpc.CallOption) (EventMaster_GetEventIdsClient, error) + GetEvents func(ctx context.Context, in *Query, opts ...grpc.CallOption) (EventMaster_GetEventsClient, error) + GetTopics func(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*TopicResult, error) + Healthcheck func(ctx context.Context, in *HealthcheckRequest, opts ...grpc.CallOption) (*HealthcheckResponse, error) + UpdateDc func(ctx context.Context, in *UpdateDcRequest, opts ...grpc.CallOption) (*WriteResponse, error) + UpdateTopic func(ctx context.Context, in *UpdateTopicRequest, opts ...grpc.CallOption) (*WriteResponse, error) + func NewEventMasterClient(cc *grpc.ClientConn) EventMasterClient + type EventMasterServer interface + AddDc func(context.Context, *Dc) (*WriteResponse, error) + AddEvent func(context.Context, *Event) (*WriteResponse, error) + AddTopic func(context.Context, *Topic) (*WriteResponse, error) + DeleteTopic func(context.Context, *DeleteTopicRequest) (*WriteResponse, error) + GetDcs func(context.Context, *EmptyRequest) (*DcResult, error) + GetEventById func(context.Context, *EventId) (*Event, error) + GetEventIds func(*TimeQuery, EventMaster_GetEventIdsServer) error + GetEvents func(*Query, EventMaster_GetEventsServer) error + GetTopics func(context.Context, *EmptyRequest) (*TopicResult, error) + Healthcheck func(context.Context, *HealthcheckRequest) (*HealthcheckResponse, error) + UpdateDc func(context.Context, *UpdateDcRequest) (*WriteResponse, error) + UpdateTopic func(context.Context, *UpdateTopicRequest) (*WriteResponse, error) + type EventMaster_GetEventIdsClient interface + Recv func() (*EventId, error) + type EventMaster_GetEventIdsServer interface + Send func(*EventId) error + type EventMaster_GetEventsClient interface + Recv func() (*Event, error) + type EventMaster_GetEventsServer interface + Send func(*Event) error + type HealthcheckRequest struct + func (*HealthcheckRequest) Descriptor() ([]byte, []int) + func (*HealthcheckRequest) ProtoMessage() + func (m *HealthcheckRequest) Reset() + func (m *HealthcheckRequest) String() string + type HealthcheckResponse struct + Response string + func (*HealthcheckResponse) Descriptor() ([]byte, []int) + func (*HealthcheckResponse) ProtoMessage() + func (m *HealthcheckResponse) GetResponse() string + func (m *HealthcheckResponse) Reset() + func (m *HealthcheckResponse) String() string + type Query struct + Data string + Dc []string + EndEventTime int64 + EndReceivedTime int64 + EventId string + ExcludeTagSet []string + Host []string + Limit int32 + ParentEventId []string + Start int32 + StartEventTime int64 + StartReceivedTime int64 + TagAndOperator bool + TagSet []string + TargetHostAndOperator bool + TargetHostSet []string + TopicName []string + User []string + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (m *Query) GetData() string + func (m *Query) GetDc() []string + func (m *Query) GetEndEventTime() int64 + func (m *Query) GetEndReceivedTime() int64 + func (m *Query) GetEventId() string + func (m *Query) GetExcludeTagSet() []string + func (m *Query) GetHost() []string + func (m *Query) GetLimit() int32 + func (m *Query) GetParentEventId() []string + func (m *Query) GetStart() int32 + func (m *Query) GetStartEventTime() int64 + func (m *Query) GetStartReceivedTime() int64 + func (m *Query) GetTagAndOperator() bool + func (m *Query) GetTagSet() []string + func (m *Query) GetTargetHostAndOperator() bool + func (m *Query) GetTargetHostSet() []string + func (m *Query) GetTopicName() []string + func (m *Query) GetUser() []string + func (m *Query) Reset() + func (m *Query) String() string + type TimeQuery struct + Ascending bool + EndEventTime int64 + Limit int32 + StartEventTime int64 + func (*TimeQuery) Descriptor() ([]byte, []int) + func (*TimeQuery) ProtoMessage() + func (m *TimeQuery) GetAscending() bool + func (m *TimeQuery) GetEndEventTime() int64 + func (m *TimeQuery) GetLimit() int32 + func (m *TimeQuery) GetStartEventTime() int64 + func (m *TimeQuery) Reset() + func (m *TimeQuery) String() string + type Topic struct + DataSchema []byte + Id string + TopicName string + func (*Topic) Descriptor() ([]byte, []int) + func (*Topic) ProtoMessage() + func (m *Topic) GetDataSchema() []byte + func (m *Topic) GetId() string + func (m *Topic) GetTopicName() string + func (m *Topic) Reset() + func (m *Topic) String() string + type TopicResult struct + Results []*Topic + func (*TopicResult) Descriptor() ([]byte, []int) + func (*TopicResult) ProtoMessage() + func (m *TopicResult) GetResults() []*Topic + func (m *TopicResult) Reset() + func (m *TopicResult) String() string + type UpdateDcRequest struct + NewName string + OldName string + func (*UpdateDcRequest) Descriptor() ([]byte, []int) + func (*UpdateDcRequest) ProtoMessage() + func (m *UpdateDcRequest) GetNewName() string + func (m *UpdateDcRequest) GetOldName() string + func (m *UpdateDcRequest) Reset() + func (m *UpdateDcRequest) String() string + type UpdateTopicRequest struct + DataSchema []byte + NewName string + OldName string + func (*UpdateTopicRequest) Descriptor() ([]byte, []int) + func (*UpdateTopicRequest) ProtoMessage() + func (m *UpdateTopicRequest) GetDataSchema() []byte + func (m *UpdateTopicRequest) GetNewName() string + func (m *UpdateTopicRequest) GetOldName() string + func (m *UpdateTopicRequest) Reset() + func (m *UpdateTopicRequest) String() string + type WriteResponse struct + Id string + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) GetId() string + func (m *WriteResponse) Reset() + func (m *WriteResponse) String() string
Go to main page