Documentation
¶
Index ¶
- func RegisterChannelHandler(s server.Server, hdlr ChannelHandler, opts ...server.HandlerOption) error
- func RegisterHealthyHandler(s server.Server, hdlr HealthyHandler, opts ...server.HandlerOption) error
- func RegisterRecordHandler(s server.Server, hdlr RecordHandler, opts ...server.HandlerOption) error
- type BlankResponse
- func (*BlankResponse) Descriptor() ([]byte, []int)
- func (m *BlankResponse) GetStatus() *Status
- func (*BlankResponse) ProtoMessage()
- func (m *BlankResponse) Reset()
- func (m *BlankResponse) String() string
- func (m *BlankResponse) XXX_DiscardUnknown()
- func (m *BlankResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BlankResponse) XXX_Merge(src proto.Message)
- func (m *BlankResponse) XXX_Size() int
- func (m *BlankResponse) XXX_Unmarshal(b []byte) error
- type ChannelEntity
- func (*ChannelEntity) Descriptor() ([]byte, []int)
- func (m *ChannelEntity) GetAlias() string
- func (m *ChannelEntity) GetNotification() string
- func (*ChannelEntity) ProtoMessage()
- func (m *ChannelEntity) Reset()
- func (m *ChannelEntity) String() string
- func (m *ChannelEntity) XXX_DiscardUnknown()
- func (m *ChannelEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelEntity) XXX_Merge(src proto.Message)
- func (m *ChannelEntity) XXX_Size() int
- func (m *ChannelEntity) XXX_Unmarshal(b []byte) error
- type ChannelFetchRequest
- func (*ChannelFetchRequest) Descriptor() ([]byte, []int)
- func (m *ChannelFetchRequest) GetCount() int64
- func (m *ChannelFetchRequest) GetOffset() int64
- func (*ChannelFetchRequest) ProtoMessage()
- func (m *ChannelFetchRequest) Reset()
- func (m *ChannelFetchRequest) String() string
- func (m *ChannelFetchRequest) XXX_DiscardUnknown()
- func (m *ChannelFetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelFetchRequest) XXX_Merge(src proto.Message)
- func (m *ChannelFetchRequest) XXX_Size() int
- func (m *ChannelFetchRequest) XXX_Unmarshal(b []byte) error
- type ChannelFetchResponse
- func (*ChannelFetchResponse) Descriptor() ([]byte, []int)
- func (m *ChannelFetchResponse) GetChannel() []*ChannelEntity
- func (m *ChannelFetchResponse) GetStatus() *Status
- func (m *ChannelFetchResponse) GetTotal() int64
- func (*ChannelFetchResponse) ProtoMessage()
- func (m *ChannelFetchResponse) Reset()
- func (m *ChannelFetchResponse) String() string
- func (m *ChannelFetchResponse) XXX_DiscardUnknown()
- func (m *ChannelFetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelFetchResponse) XXX_Merge(src proto.Message)
- func (m *ChannelFetchResponse) XXX_Size() int
- func (m *ChannelFetchResponse) XXX_Unmarshal(b []byte) error
- type ChannelHandler
- type ChannelService
- type ChannelSubRequest
- func (*ChannelSubRequest) Descriptor() ([]byte, []int)
- func (m *ChannelSubRequest) GetNotification() string
- func (*ChannelSubRequest) ProtoMessage()
- func (m *ChannelSubRequest) Reset()
- func (m *ChannelSubRequest) String() string
- func (m *ChannelSubRequest) XXX_DiscardUnknown()
- func (m *ChannelSubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelSubRequest) XXX_Merge(src proto.Message)
- func (m *ChannelSubRequest) XXX_Size() int
- func (m *ChannelSubRequest) XXX_Unmarshal(b []byte) error
- type ChannelUnsubRequest
- func (*ChannelUnsubRequest) Descriptor() ([]byte, []int)
- func (m *ChannelUnsubRequest) GetNotification() string
- func (*ChannelUnsubRequest) ProtoMessage()
- func (m *ChannelUnsubRequest) Reset()
- func (m *ChannelUnsubRequest) String() string
- func (m *ChannelUnsubRequest) XXX_DiscardUnknown()
- func (m *ChannelUnsubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelUnsubRequest) XXX_Merge(src proto.Message)
- func (m *ChannelUnsubRequest) XXX_Size() int
- func (m *ChannelUnsubRequest) XXX_Unmarshal(b []byte) error
- type EchoRequest
- func (*EchoRequest) Descriptor() ([]byte, []int)
- func (m *EchoRequest) GetMsg() string
- func (*EchoRequest) ProtoMessage()
- func (m *EchoRequest) Reset()
- func (m *EchoRequest) String() string
- func (m *EchoRequest) XXX_DiscardUnknown()
- func (m *EchoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoRequest) XXX_Merge(src proto.Message)
- func (m *EchoRequest) XXX_Size() int
- func (m *EchoRequest) XXX_Unmarshal(b []byte) error
- type EchoResponse
- func (*EchoResponse) Descriptor() ([]byte, []int)
- func (m *EchoResponse) GetMsg() string
- func (*EchoResponse) ProtoMessage()
- func (m *EchoResponse) Reset()
- func (m *EchoResponse) String() string
- func (m *EchoResponse) XXX_DiscardUnknown()
- func (m *EchoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EchoResponse) XXX_Merge(src proto.Message)
- func (m *EchoResponse) XXX_Size() int
- func (m *EchoResponse) XXX_Unmarshal(b []byte) error
- type HealthyHandler
- type HealthyService
- type Operator
- func (*Operator) Descriptor() ([]byte, []int)
- func (m *Operator) GetLabel() string
- func (m *Operator) GetType() string
- func (*Operator) ProtoMessage()
- func (m *Operator) Reset()
- func (m *Operator) String() string
- func (m *Operator) XXX_DiscardUnknown()
- func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Operator) XXX_Merge(src proto.Message)
- func (m *Operator) XXX_Size() int
- func (m *Operator) XXX_Unmarshal(b []byte) error
- type RecordEntity
- func (*RecordEntity) Descriptor() ([]byte, []int)
- func (m *RecordEntity) GetAction() string
- func (m *RecordEntity) GetBody() string
- func (m *RecordEntity) GetChannel() *ChannelEntity
- func (m *RecordEntity) GetHead() string
- func (m *RecordEntity) GetOperator() *Operator
- func (m *RecordEntity) GetTime() int64
- func (*RecordEntity) ProtoMessage()
- func (m *RecordEntity) Reset()
- func (m *RecordEntity) String() string
- func (m *RecordEntity) XXX_DiscardUnknown()
- func (m *RecordEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordEntity) XXX_Merge(src proto.Message)
- func (m *RecordEntity) XXX_Size() int
- func (m *RecordEntity) XXX_Unmarshal(b []byte) error
- type RecordFetchRequest
- func (*RecordFetchRequest) Descriptor() ([]byte, []int)
- func (m *RecordFetchRequest) GetAction() string
- func (m *RecordFetchRequest) GetEndTime() int64
- func (m *RecordFetchRequest) GetNotification() string
- func (m *RecordFetchRequest) GetStartTime() int64
- func (*RecordFetchRequest) ProtoMessage()
- func (m *RecordFetchRequest) Reset()
- func (m *RecordFetchRequest) String() string
- func (m *RecordFetchRequest) XXX_DiscardUnknown()
- func (m *RecordFetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordFetchRequest) XXX_Merge(src proto.Message)
- func (m *RecordFetchRequest) XXX_Size() int
- func (m *RecordFetchRequest) XXX_Unmarshal(b []byte) error
- type RecordFetchResponse
- func (*RecordFetchResponse) Descriptor() ([]byte, []int)
- func (m *RecordFetchResponse) GetRecord() []*RecordEntity
- func (m *RecordFetchResponse) GetStatus() *Status
- func (*RecordFetchResponse) ProtoMessage()
- func (m *RecordFetchResponse) Reset()
- func (m *RecordFetchResponse) String() string
- func (m *RecordFetchResponse) XXX_DiscardUnknown()
- func (m *RecordFetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordFetchResponse) XXX_Merge(src proto.Message)
- func (m *RecordFetchResponse) XXX_Size() int
- func (m *RecordFetchResponse) XXX_Unmarshal(b []byte) error
- type RecordHandler
- type RecordService
- type Status
- func (*Status) Descriptor() ([]byte, []int)
- func (m *Status) GetCode() int32
- func (m *Status) GetMessage() string
- func (*Status) ProtoMessage()
- func (m *Status) Reset()
- func (m *Status) String() string
- func (m *Status) XXX_DiscardUnknown()
- func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Status) XXX_Merge(src proto.Message)
- func (m *Status) XXX_Size() int
- func (m *Status) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterChannelHandler ¶
func RegisterChannelHandler(s server.Server, hdlr ChannelHandler, opts ...server.HandlerOption) error
func RegisterHealthyHandler ¶ added in v1.2.0
func RegisterHealthyHandler(s server.Server, hdlr HealthyHandler, opts ...server.HandlerOption) error
func RegisterRecordHandler ¶
func RegisterRecordHandler(s server.Server, hdlr RecordHandler, opts ...server.HandlerOption) error
Types ¶
type BlankResponse ¶
type BlankResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BlankResponse) Descriptor ¶
func (*BlankResponse) Descriptor() ([]byte, []int)
func (*BlankResponse) GetStatus ¶
func (m *BlankResponse) GetStatus() *Status
func (*BlankResponse) ProtoMessage ¶
func (*BlankResponse) ProtoMessage()
func (*BlankResponse) Reset ¶
func (m *BlankResponse) Reset()
func (*BlankResponse) String ¶
func (m *BlankResponse) String() string
func (*BlankResponse) XXX_DiscardUnknown ¶
func (m *BlankResponse) XXX_DiscardUnknown()
func (*BlankResponse) XXX_Marshal ¶
func (m *BlankResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BlankResponse) XXX_Merge ¶
func (m *BlankResponse) XXX_Merge(src proto.Message)
func (*BlankResponse) XXX_Size ¶
func (m *BlankResponse) XXX_Size() int
func (*BlankResponse) XXX_Unmarshal ¶
func (m *BlankResponse) XXX_Unmarshal(b []byte) error
type ChannelEntity ¶
type ChannelEntity struct { Notification string `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
频道实体
func (*ChannelEntity) Descriptor ¶
func (*ChannelEntity) Descriptor() ([]byte, []int)
func (*ChannelEntity) GetAlias ¶
func (m *ChannelEntity) GetAlias() string
func (*ChannelEntity) GetNotification ¶
func (m *ChannelEntity) GetNotification() string
func (*ChannelEntity) ProtoMessage ¶
func (*ChannelEntity) ProtoMessage()
func (*ChannelEntity) Reset ¶
func (m *ChannelEntity) Reset()
func (*ChannelEntity) String ¶
func (m *ChannelEntity) String() string
func (*ChannelEntity) XXX_DiscardUnknown ¶
func (m *ChannelEntity) XXX_DiscardUnknown()
func (*ChannelEntity) XXX_Marshal ¶
func (m *ChannelEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelEntity) XXX_Merge ¶
func (m *ChannelEntity) XXX_Merge(src proto.Message)
func (*ChannelEntity) XXX_Size ¶
func (m *ChannelEntity) XXX_Size() int
func (*ChannelEntity) XXX_Unmarshal ¶
func (m *ChannelEntity) XXX_Unmarshal(b []byte) error
type ChannelFetchRequest ¶
type ChannelFetchRequest struct { Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
获取频道列表的请求
func (*ChannelFetchRequest) Descriptor ¶
func (*ChannelFetchRequest) Descriptor() ([]byte, []int)
func (*ChannelFetchRequest) GetCount ¶
func (m *ChannelFetchRequest) GetCount() int64
func (*ChannelFetchRequest) GetOffset ¶
func (m *ChannelFetchRequest) GetOffset() int64
func (*ChannelFetchRequest) ProtoMessage ¶
func (*ChannelFetchRequest) ProtoMessage()
func (*ChannelFetchRequest) Reset ¶
func (m *ChannelFetchRequest) Reset()
func (*ChannelFetchRequest) String ¶
func (m *ChannelFetchRequest) String() string
func (*ChannelFetchRequest) XXX_DiscardUnknown ¶
func (m *ChannelFetchRequest) XXX_DiscardUnknown()
func (*ChannelFetchRequest) XXX_Marshal ¶
func (m *ChannelFetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelFetchRequest) XXX_Merge ¶
func (m *ChannelFetchRequest) XXX_Merge(src proto.Message)
func (*ChannelFetchRequest) XXX_Size ¶
func (m *ChannelFetchRequest) XXX_Size() int
func (*ChannelFetchRequest) XXX_Unmarshal ¶
func (m *ChannelFetchRequest) XXX_Unmarshal(b []byte) error
type ChannelFetchResponse ¶
type ChannelFetchResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Total int64 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` Channel []*ChannelEntity `protobuf:"bytes,3,rep,name=channel,proto3" json:"channel,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
获取频道列表的回复
func (*ChannelFetchResponse) Descriptor ¶
func (*ChannelFetchResponse) Descriptor() ([]byte, []int)
func (*ChannelFetchResponse) GetChannel ¶
func (m *ChannelFetchResponse) GetChannel() []*ChannelEntity
func (*ChannelFetchResponse) GetStatus ¶
func (m *ChannelFetchResponse) GetStatus() *Status
func (*ChannelFetchResponse) GetTotal ¶ added in v1.1.0
func (m *ChannelFetchResponse) GetTotal() int64
func (*ChannelFetchResponse) ProtoMessage ¶
func (*ChannelFetchResponse) ProtoMessage()
func (*ChannelFetchResponse) Reset ¶
func (m *ChannelFetchResponse) Reset()
func (*ChannelFetchResponse) String ¶
func (m *ChannelFetchResponse) String() string
func (*ChannelFetchResponse) XXX_DiscardUnknown ¶
func (m *ChannelFetchResponse) XXX_DiscardUnknown()
func (*ChannelFetchResponse) XXX_Marshal ¶
func (m *ChannelFetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelFetchResponse) XXX_Merge ¶
func (m *ChannelFetchResponse) XXX_Merge(src proto.Message)
func (*ChannelFetchResponse) XXX_Size ¶
func (m *ChannelFetchResponse) XXX_Size() int
func (*ChannelFetchResponse) XXX_Unmarshal ¶
func (m *ChannelFetchResponse) XXX_Unmarshal(b []byte) error
type ChannelHandler ¶
type ChannelHandler interface { // 订阅 Subscribe(context.Context, *ChannelSubRequest, *BlankResponse) error // 取消订阅 Unsubscribe(context.Context, *ChannelUnsubRequest, *BlankResponse) error // 获取列表 Fetch(context.Context, *ChannelFetchRequest, *ChannelFetchResponse) error }
type ChannelService ¶
type ChannelService interface { // 订阅 Subscribe(ctx context.Context, in *ChannelSubRequest, opts ...client.CallOption) (*BlankResponse, error) // 取消订阅 Unsubscribe(ctx context.Context, in *ChannelUnsubRequest, opts ...client.CallOption) (*BlankResponse, error) // 获取列表 Fetch(ctx context.Context, in *ChannelFetchRequest, opts ...client.CallOption) (*ChannelFetchResponse, error) }
func NewChannelService ¶
func NewChannelService(name string, c client.Client) ChannelService
type ChannelSubRequest ¶
type ChannelSubRequest struct { Notification string `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
频道订阅的请求
func (*ChannelSubRequest) Descriptor ¶
func (*ChannelSubRequest) Descriptor() ([]byte, []int)
func (*ChannelSubRequest) GetNotification ¶
func (m *ChannelSubRequest) GetNotification() string
func (*ChannelSubRequest) ProtoMessage ¶
func (*ChannelSubRequest) ProtoMessage()
func (*ChannelSubRequest) Reset ¶
func (m *ChannelSubRequest) Reset()
func (*ChannelSubRequest) String ¶
func (m *ChannelSubRequest) String() string
func (*ChannelSubRequest) XXX_DiscardUnknown ¶
func (m *ChannelSubRequest) XXX_DiscardUnknown()
func (*ChannelSubRequest) XXX_Marshal ¶
func (m *ChannelSubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelSubRequest) XXX_Merge ¶
func (m *ChannelSubRequest) XXX_Merge(src proto.Message)
func (*ChannelSubRequest) XXX_Size ¶
func (m *ChannelSubRequest) XXX_Size() int
func (*ChannelSubRequest) XXX_Unmarshal ¶
func (m *ChannelSubRequest) XXX_Unmarshal(b []byte) error
type ChannelUnsubRequest ¶
type ChannelUnsubRequest struct { Notification string `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
频道取消订阅的请求
func (*ChannelUnsubRequest) Descriptor ¶
func (*ChannelUnsubRequest) Descriptor() ([]byte, []int)
func (*ChannelUnsubRequest) GetNotification ¶
func (m *ChannelUnsubRequest) GetNotification() string
func (*ChannelUnsubRequest) ProtoMessage ¶
func (*ChannelUnsubRequest) ProtoMessage()
func (*ChannelUnsubRequest) Reset ¶
func (m *ChannelUnsubRequest) Reset()
func (*ChannelUnsubRequest) String ¶
func (m *ChannelUnsubRequest) String() string
func (*ChannelUnsubRequest) XXX_DiscardUnknown ¶
func (m *ChannelUnsubRequest) XXX_DiscardUnknown()
func (*ChannelUnsubRequest) XXX_Marshal ¶
func (m *ChannelUnsubRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelUnsubRequest) XXX_Merge ¶
func (m *ChannelUnsubRequest) XXX_Merge(src proto.Message)
func (*ChannelUnsubRequest) XXX_Size ¶
func (m *ChannelUnsubRequest) XXX_Size() int
func (*ChannelUnsubRequest) XXX_Unmarshal ¶
func (m *ChannelUnsubRequest) XXX_Unmarshal(b []byte) error
type EchoRequest ¶ added in v1.2.0
type EchoRequest struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
回显的请求
func (*EchoRequest) Descriptor ¶ added in v1.2.0
func (*EchoRequest) Descriptor() ([]byte, []int)
func (*EchoRequest) GetMsg ¶ added in v1.2.0
func (m *EchoRequest) GetMsg() string
func (*EchoRequest) ProtoMessage ¶ added in v1.2.0
func (*EchoRequest) ProtoMessage()
func (*EchoRequest) Reset ¶ added in v1.2.0
func (m *EchoRequest) Reset()
func (*EchoRequest) String ¶ added in v1.2.0
func (m *EchoRequest) String() string
func (*EchoRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *EchoRequest) XXX_DiscardUnknown()
func (*EchoRequest) XXX_Marshal ¶ added in v1.2.0
func (m *EchoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoRequest) XXX_Merge ¶ added in v1.2.0
func (m *EchoRequest) XXX_Merge(src proto.Message)
func (*EchoRequest) XXX_Size ¶ added in v1.2.0
func (m *EchoRequest) XXX_Size() int
func (*EchoRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *EchoRequest) XXX_Unmarshal(b []byte) error
type EchoResponse ¶ added in v1.2.0
type EchoResponse struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
回显的回复
func (*EchoResponse) Descriptor ¶ added in v1.2.0
func (*EchoResponse) Descriptor() ([]byte, []int)
func (*EchoResponse) GetMsg ¶ added in v1.2.0
func (m *EchoResponse) GetMsg() string
func (*EchoResponse) ProtoMessage ¶ added in v1.2.0
func (*EchoResponse) ProtoMessage()
func (*EchoResponse) Reset ¶ added in v1.2.0
func (m *EchoResponse) Reset()
func (*EchoResponse) String ¶ added in v1.2.0
func (m *EchoResponse) String() string
func (*EchoResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *EchoResponse) XXX_DiscardUnknown()
func (*EchoResponse) XXX_Marshal ¶ added in v1.2.0
func (m *EchoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EchoResponse) XXX_Merge ¶ added in v1.2.0
func (m *EchoResponse) XXX_Merge(src proto.Message)
func (*EchoResponse) XXX_Size ¶ added in v1.2.0
func (m *EchoResponse) XXX_Size() int
func (*EchoResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *EchoResponse) XXX_Unmarshal(b []byte) error
type HealthyHandler ¶ added in v1.2.0
type HealthyHandler interface { // 回显 Echo(context.Context, *EchoRequest, *EchoResponse) error }
type HealthyService ¶ added in v1.2.0
type HealthyService interface { // 回显 Echo(ctx context.Context, in *EchoRequest, opts ...client.CallOption) (*EchoResponse, error) }
func NewHealthyService ¶ added in v1.2.0
func NewHealthyService(name string, c client.Client) HealthyService
type Operator ¶
type Operator struct { Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
操作员
func (*Operator) Descriptor ¶
func (*Operator) ProtoMessage ¶
func (*Operator) ProtoMessage()
func (*Operator) XXX_DiscardUnknown ¶
func (m *Operator) XXX_DiscardUnknown()
func (*Operator) XXX_Marshal ¶
func (*Operator) XXX_Unmarshal ¶
type RecordEntity ¶
type RecordEntity struct { Operator *Operator `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"` Channel *ChannelEntity `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"` Action string `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"` Head string `protobuf:"bytes,4,opt,name=head,proto3" json:"head,omitempty"` Body string `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"` Time int64 `protobuf:"varint,6,opt,name=time,proto3" json:"time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
记录实体
func (*RecordEntity) Descriptor ¶
func (*RecordEntity) Descriptor() ([]byte, []int)
func (*RecordEntity) GetAction ¶
func (m *RecordEntity) GetAction() string
func (*RecordEntity) GetBody ¶
func (m *RecordEntity) GetBody() string
func (*RecordEntity) GetChannel ¶
func (m *RecordEntity) GetChannel() *ChannelEntity
func (*RecordEntity) GetHead ¶
func (m *RecordEntity) GetHead() string
func (*RecordEntity) GetOperator ¶
func (m *RecordEntity) GetOperator() *Operator
func (*RecordEntity) GetTime ¶
func (m *RecordEntity) GetTime() int64
func (*RecordEntity) ProtoMessage ¶
func (*RecordEntity) ProtoMessage()
func (*RecordEntity) Reset ¶
func (m *RecordEntity) Reset()
func (*RecordEntity) String ¶
func (m *RecordEntity) String() string
func (*RecordEntity) XXX_DiscardUnknown ¶
func (m *RecordEntity) XXX_DiscardUnknown()
func (*RecordEntity) XXX_Marshal ¶
func (m *RecordEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordEntity) XXX_Merge ¶
func (m *RecordEntity) XXX_Merge(src proto.Message)
func (*RecordEntity) XXX_Size ¶
func (m *RecordEntity) XXX_Size() int
func (*RecordEntity) XXX_Unmarshal ¶
func (m *RecordEntity) XXX_Unmarshal(b []byte) error
type RecordFetchRequest ¶
type RecordFetchRequest struct { StartTime int64 `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"` EndTime int64 `protobuf:"varint,2,opt,name=endTime,proto3" json:"endTime,omitempty"` Notification string `protobuf:"bytes,3,opt,name=notification,proto3" json:"notification,omitempty"` Action string `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
获取记录列表的请求
func (*RecordFetchRequest) Descriptor ¶
func (*RecordFetchRequest) Descriptor() ([]byte, []int)
func (*RecordFetchRequest) GetAction ¶
func (m *RecordFetchRequest) GetAction() string
func (*RecordFetchRequest) GetEndTime ¶
func (m *RecordFetchRequest) GetEndTime() int64
func (*RecordFetchRequest) GetNotification ¶
func (m *RecordFetchRequest) GetNotification() string
func (*RecordFetchRequest) GetStartTime ¶
func (m *RecordFetchRequest) GetStartTime() int64
func (*RecordFetchRequest) ProtoMessage ¶
func (*RecordFetchRequest) ProtoMessage()
func (*RecordFetchRequest) Reset ¶
func (m *RecordFetchRequest) Reset()
func (*RecordFetchRequest) String ¶
func (m *RecordFetchRequest) String() string
func (*RecordFetchRequest) XXX_DiscardUnknown ¶
func (m *RecordFetchRequest) XXX_DiscardUnknown()
func (*RecordFetchRequest) XXX_Marshal ¶
func (m *RecordFetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordFetchRequest) XXX_Merge ¶
func (m *RecordFetchRequest) XXX_Merge(src proto.Message)
func (*RecordFetchRequest) XXX_Size ¶
func (m *RecordFetchRequest) XXX_Size() int
func (*RecordFetchRequest) XXX_Unmarshal ¶
func (m *RecordFetchRequest) XXX_Unmarshal(b []byte) error
type RecordFetchResponse ¶
type RecordFetchResponse struct { Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Record []*RecordEntity `protobuf:"bytes,2,rep,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
获取记录列表的回复
func (*RecordFetchResponse) Descriptor ¶
func (*RecordFetchResponse) Descriptor() ([]byte, []int)
func (*RecordFetchResponse) GetRecord ¶
func (m *RecordFetchResponse) GetRecord() []*RecordEntity
func (*RecordFetchResponse) GetStatus ¶
func (m *RecordFetchResponse) GetStatus() *Status
func (*RecordFetchResponse) ProtoMessage ¶
func (*RecordFetchResponse) ProtoMessage()
func (*RecordFetchResponse) Reset ¶
func (m *RecordFetchResponse) Reset()
func (*RecordFetchResponse) String ¶
func (m *RecordFetchResponse) String() string
func (*RecordFetchResponse) XXX_DiscardUnknown ¶
func (m *RecordFetchResponse) XXX_DiscardUnknown()
func (*RecordFetchResponse) XXX_Marshal ¶
func (m *RecordFetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordFetchResponse) XXX_Merge ¶
func (m *RecordFetchResponse) XXX_Merge(src proto.Message)
func (*RecordFetchResponse) XXX_Size ¶
func (m *RecordFetchResponse) XXX_Size() int
func (*RecordFetchResponse) XXX_Unmarshal ¶
func (m *RecordFetchResponse) XXX_Unmarshal(b []byte) error
type RecordHandler ¶
type RecordHandler interface { // 获取列表 Fetch(context.Context, *RecordFetchRequest, *RecordFetchResponse) error }
type RecordService ¶
type RecordService interface { // 获取列表 Fetch(ctx context.Context, in *RecordFetchRequest, opts ...client.CallOption) (*RecordFetchResponse, error) }
func NewRecordService ¶
func NewRecordService(name string, c client.Client) RecordService
type Status ¶
type Status struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
状态
func (*Status) Descriptor ¶
func (*Status) GetMessage ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) XXX_DiscardUnknown ¶
func (m *Status) XXX_DiscardUnknown()
func (*Status) XXX_Marshal ¶
func (*Status) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.