activity

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 11, 2021 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*Operator) GetLabel

func (m *Operator) GetLabel() string

func (*Operator) GetType

func (m *Operator) GetType() string

func (*Operator) ProtoMessage

func (*Operator) ProtoMessage()

func (*Operator) Reset

func (m *Operator) Reset()

func (*Operator) String

func (m *Operator) String() string

func (*Operator) XXX_DiscardUnknown

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal

func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operator) XXX_Merge

func (m *Operator) XXX_Merge(src proto.Message)

func (*Operator) XXX_Size

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal

func (m *Operator) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Status) GetCode

func (m *Status) GetCode() int32

func (*Status) GetMessage

func (m *Status) GetMessage() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

func (*Status) XXX_DiscardUnknown

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal

func (m *Status) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL