subscriber_manager

package
v0.0.0-...-b63aa1a Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterService 

func RegisterService(s giraffe_micro.Server, srv Service)

Types

type Client 

type Client interface {
	PubSubscriberCreate(ctx context.Context, in *PubSubscriberCreateRequest) (*PubSubscriberCreateResponse, error)
	PubSubscriberDelete(ctx context.Context, in *PubSubscriberDeleteRequest) (*types.Empty, error)
	PubSubscriberList(ctx context.Context, in *PubSubscriberListRequest) (*PubSubscriberListResponse, error)
	PubSubscriberUpdate(ctx context.Context, in *PubSubscriberUpdateRequest) (*PubSubscriberUpdateResponse, error)
}

Client is the client API for subscriber_manager service.

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

func NewClient 

func NewClient(c giraffe_micro.Client) Client

type PubSubscriberCreateRequest 

type PubSubscriberCreateRequest struct {
	//
	//订阅的事件id列表
	Topics []string `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics" form:"topics"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name" form:"name"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,4,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,5,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,6,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberCreate请求

func (*PubSubscriberCreateRequest) Descriptor 

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

func (*PubSubscriberCreateRequest) GetCallback 

func (m *PubSubscriberCreateRequest) GetCallback() string

func (*PubSubscriberCreateRequest) GetEnsName 

func (m *PubSubscriberCreateRequest) GetEnsName() string

func (*PubSubscriberCreateRequest) GetName 

func (m *PubSubscriberCreateRequest) GetName() string

func (*PubSubscriberCreateRequest) GetRetry 

func (m *PubSubscriberCreateRequest) GetRetry() int32

func (*PubSubscriberCreateRequest) GetTopicVersion 

func (m *PubSubscriberCreateRequest) GetTopicVersion() int32

func (*PubSubscriberCreateRequest) GetTopics 

func (m *PubSubscriberCreateRequest) GetTopics() []string

func (*PubSubscriberCreateRequest) ProtoMessage 

func (*PubSubscriberCreateRequest) ProtoMessage()

func (*PubSubscriberCreateRequest) Reset 

func (m *PubSubscriberCreateRequest) Reset()

func (*PubSubscriberCreateRequest) String 

func (m *PubSubscriberCreateRequest) String() string

func (*PubSubscriberCreateRequest) Validate 

func (this *PubSubscriberCreateRequest) Validate() error

func (*PubSubscriberCreateRequest) XXX_DiscardUnknown 

func (m *PubSubscriberCreateRequest) XXX_DiscardUnknown()

func (*PubSubscriberCreateRequest) XXX_Marshal 

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

func (*PubSubscriberCreateRequest) XXX_Merge 

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

func (*PubSubscriberCreateRequest) XXX_Size 

func (m *PubSubscriberCreateRequest) XXX_Size() int

func (*PubSubscriberCreateRequest) XXX_Unmarshal 

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

type PubSubscriberCreateResponse 

type PubSubscriberCreateResponse struct {
	//
	//订阅的事件列表
	Topics []*notify.Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics" form:"topics"`
	//
	//订阅ID
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	//
	//订阅负责人。如 linus
	Admin string `protobuf:"bytes,4,opt,name=admin,proto3" json:"admin" form:"admin"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,5,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,6,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,7,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//模型修改时间
	Mtime string `protobuf:"bytes,8,opt,name=mtime,proto3" json:"mtime" form:"mtime"`
	//
	//模型版本
	XVersion int32 `protobuf:"varint,9,opt,name=_version,json=Version,proto3" json:"_version" form:"_version"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,10,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberCreate返回

func (*PubSubscriberCreateResponse) Descriptor 

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

func (*PubSubscriberCreateResponse) GetAdmin 

func (m *PubSubscriberCreateResponse) GetAdmin() string

func (*PubSubscriberCreateResponse) GetCallback 

func (m *PubSubscriberCreateResponse) GetCallback() string

func (*PubSubscriberCreateResponse) GetEnsName 

func (m *PubSubscriberCreateResponse) GetEnsName() string

func (*PubSubscriberCreateResponse) GetInstanceId 

func (m *PubSubscriberCreateResponse) GetInstanceId() string

func (*PubSubscriberCreateResponse) GetMtime 

func (m *PubSubscriberCreateResponse) GetMtime() string

func (*PubSubscriberCreateResponse) GetName 

func (m *PubSubscriberCreateResponse) GetName() string

func (*PubSubscriberCreateResponse) GetRetry 

func (m *PubSubscriberCreateResponse) GetRetry() int32

func (*PubSubscriberCreateResponse) GetTopicVersion 

func (m *PubSubscriberCreateResponse) GetTopicVersion() int32

func (*PubSubscriberCreateResponse) GetTopics 

func (m *PubSubscriberCreateResponse) GetTopics() []*notify.Topic

func (*PubSubscriberCreateResponse) GetXVersion 

func (m *PubSubscriberCreateResponse) GetXVersion() int32

func (*PubSubscriberCreateResponse) ProtoMessage 

func (*PubSubscriberCreateResponse) ProtoMessage()

func (*PubSubscriberCreateResponse) Reset 

func (m *PubSubscriberCreateResponse) Reset()

func (*PubSubscriberCreateResponse) String 

func (m *PubSubscriberCreateResponse) String() string

func (*PubSubscriberCreateResponse) Validate 

func (this *PubSubscriberCreateResponse) Validate() error

func (*PubSubscriberCreateResponse) XXX_DiscardUnknown 

func (m *PubSubscriberCreateResponse) XXX_DiscardUnknown()

func (*PubSubscriberCreateResponse) XXX_Marshal 

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

func (*PubSubscriberCreateResponse) XXX_Merge 

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

func (*PubSubscriberCreateResponse) XXX_Size 

func (m *PubSubscriberCreateResponse) XXX_Size() int

func (*PubSubscriberCreateResponse) XXX_Unmarshal 

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

type PubSubscriberCreateResponseWrapper 

type PubSubscriberCreateResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *PubSubscriberCreateResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

PubSubscriberCreateApi返回

func (*PubSubscriberCreateResponseWrapper) Descriptor 

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

func (*PubSubscriberCreateResponseWrapper) GetCode 

func (m *PubSubscriberCreateResponseWrapper) GetCode() int32

func (*PubSubscriberCreateResponseWrapper) GetCodeExplain 

func (m *PubSubscriberCreateResponseWrapper) GetCodeExplain() string

func (*PubSubscriberCreateResponseWrapper) GetData 

func (m *PubSubscriberCreateResponseWrapper) GetData() *PubSubscriberCreateResponse

func (*PubSubscriberCreateResponseWrapper) GetError 

func (m *PubSubscriberCreateResponseWrapper) GetError() string

func (*PubSubscriberCreateResponseWrapper) ProtoMessage 

func (*PubSubscriberCreateResponseWrapper) ProtoMessage()

func (*PubSubscriberCreateResponseWrapper) Reset 

func (m *PubSubscriberCreateResponseWrapper) Reset()

func (*PubSubscriberCreateResponseWrapper) String 

func (m *PubSubscriberCreateResponseWrapper) String() string

func (*PubSubscriberCreateResponseWrapper) Validate 

func (this *PubSubscriberCreateResponseWrapper) Validate() error

func (*PubSubscriberCreateResponseWrapper) XXX_DiscardUnknown 

func (m *PubSubscriberCreateResponseWrapper) XXX_DiscardUnknown()

func (*PubSubscriberCreateResponseWrapper) XXX_Marshal 

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

func (*PubSubscriberCreateResponseWrapper) XXX_Merge 

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

func (*PubSubscriberCreateResponseWrapper) XXX_Size 

func (m *PubSubscriberCreateResponseWrapper) XXX_Size() int

func (*PubSubscriberCreateResponseWrapper) XXX_Unmarshal 

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

type PubSubscriberDeleteRequest 

type PubSubscriberDeleteRequest struct {
	//
	//订阅id
	SubscriberId         string   `protobuf:"bytes,1,opt,name=subscriberId,proto3" json:"subscriberId" form:"subscriberId"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberDelete请求

func (*PubSubscriberDeleteRequest) Descriptor 

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

func (*PubSubscriberDeleteRequest) GetSubscriberId 

func (m *PubSubscriberDeleteRequest) GetSubscriberId() string

func (*PubSubscriberDeleteRequest) ProtoMessage 

func (*PubSubscriberDeleteRequest) ProtoMessage()

func (*PubSubscriberDeleteRequest) Reset 

func (m *PubSubscriberDeleteRequest) Reset()

func (*PubSubscriberDeleteRequest) String 

func (m *PubSubscriberDeleteRequest) String() string

func (*PubSubscriberDeleteRequest) Validate 

func (this *PubSubscriberDeleteRequest) Validate() error

func (*PubSubscriberDeleteRequest) XXX_DiscardUnknown 

func (m *PubSubscriberDeleteRequest) XXX_DiscardUnknown()

func (*PubSubscriberDeleteRequest) XXX_Marshal 

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

func (*PubSubscriberDeleteRequest) XXX_Merge 

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

func (*PubSubscriberDeleteRequest) XXX_Size 

func (m *PubSubscriberDeleteRequest) XXX_Size() int

func (*PubSubscriberDeleteRequest) XXX_Unmarshal 

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

type PubSubscriberDeleteResponseWrapper 

type PubSubscriberDeleteResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *types.Empty `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

PubSubscriberDeleteApi返回

func (*PubSubscriberDeleteResponseWrapper) Descriptor 

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

func (*PubSubscriberDeleteResponseWrapper) GetCode 

func (m *PubSubscriberDeleteResponseWrapper) GetCode() int32

func (*PubSubscriberDeleteResponseWrapper) GetCodeExplain 

func (m *PubSubscriberDeleteResponseWrapper) GetCodeExplain() string

func (*PubSubscriberDeleteResponseWrapper) GetData 

func (m *PubSubscriberDeleteResponseWrapper) GetData() *types.Empty

func (*PubSubscriberDeleteResponseWrapper) GetError 

func (m *PubSubscriberDeleteResponseWrapper) GetError() string

func (*PubSubscriberDeleteResponseWrapper) ProtoMessage 

func (*PubSubscriberDeleteResponseWrapper) ProtoMessage()

func (*PubSubscriberDeleteResponseWrapper) Reset 

func (m *PubSubscriberDeleteResponseWrapper) Reset()

func (*PubSubscriberDeleteResponseWrapper) String 

func (m *PubSubscriberDeleteResponseWrapper) String() string

func (*PubSubscriberDeleteResponseWrapper) Validate 

func (this *PubSubscriberDeleteResponseWrapper) Validate() error

func (*PubSubscriberDeleteResponseWrapper) XXX_DiscardUnknown 

func (m *PubSubscriberDeleteResponseWrapper) XXX_DiscardUnknown()

func (*PubSubscriberDeleteResponseWrapper) XXX_Marshal 

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

func (*PubSubscriberDeleteResponseWrapper) XXX_Merge 

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

func (*PubSubscriberDeleteResponseWrapper) XXX_Size 

func (m *PubSubscriberDeleteResponseWrapper) XXX_Size() int

func (*PubSubscriberDeleteResponseWrapper) XXX_Unmarshal 

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

type PubSubscriberListRequest 

type PubSubscriberListRequest struct {
	//
	//页码
	Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page" form:"page"`
	//
	//每页大小
	PageSize             int32    `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size" form:"page_size"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberList请求

func (*PubSubscriberListRequest) Descriptor 

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

func (*PubSubscriberListRequest) GetPage 

func (m *PubSubscriberListRequest) GetPage() int32

func (*PubSubscriberListRequest) GetPageSize 

func (m *PubSubscriberListRequest) GetPageSize() int32

func (*PubSubscriberListRequest) ProtoMessage 

func (*PubSubscriberListRequest) ProtoMessage()

func (*PubSubscriberListRequest) Reset 

func (m *PubSubscriberListRequest) Reset()

func (*PubSubscriberListRequest) String 

func (m *PubSubscriberListRequest) String() string

func (*PubSubscriberListRequest) Validate 

func (this *PubSubscriberListRequest) Validate() error

func (*PubSubscriberListRequest) XXX_DiscardUnknown 

func (m *PubSubscriberListRequest) XXX_DiscardUnknown()

func (*PubSubscriberListRequest) XXX_Marshal 

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

func (*PubSubscriberListRequest) XXX_Merge 

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

func (*PubSubscriberListRequest) XXX_Size 

func (m *PubSubscriberListRequest) XXX_Size() int

func (*PubSubscriberListRequest) XXX_Unmarshal 

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

type PubSubscriberListResponse 

type PubSubscriberListResponse struct {
	//
	//页数
	Page int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page" form:"page"`
	//
	//页大小
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size" form:"page_size"`
	//
	//总数
	Total int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total" form:"total"`
	//
	//数据列表
	List                 []*PubSubscriberListResponse_List `protobuf:"bytes,4,rep,name=list,proto3" json:"list" form:"list"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

PubSubscriberList返回

func (*PubSubscriberListResponse) Descriptor 

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

func (*PubSubscriberListResponse) GetList 

func (m *PubSubscriberListResponse) GetList() []*PubSubscriberListResponse_List

func (*PubSubscriberListResponse) GetPage 

func (m *PubSubscriberListResponse) GetPage() int32

func (*PubSubscriberListResponse) GetPageSize 

func (m *PubSubscriberListResponse) GetPageSize() int32

func (*PubSubscriberListResponse) GetTotal 

func (m *PubSubscriberListResponse) GetTotal() int32

func (*PubSubscriberListResponse) ProtoMessage 

func (*PubSubscriberListResponse) ProtoMessage()

func (*PubSubscriberListResponse) Reset 

func (m *PubSubscriberListResponse) Reset()

func (*PubSubscriberListResponse) String 

func (m *PubSubscriberListResponse) String() string

func (*PubSubscriberListResponse) Validate 

func (this *PubSubscriberListResponse) Validate() error

func (*PubSubscriberListResponse) XXX_DiscardUnknown 

func (m *PubSubscriberListResponse) XXX_DiscardUnknown()

func (*PubSubscriberListResponse) XXX_Marshal 

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

func (*PubSubscriberListResponse) XXX_Merge 

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

func (*PubSubscriberListResponse) XXX_Size 

func (m *PubSubscriberListResponse) XXX_Size() int

func (*PubSubscriberListResponse) XXX_Unmarshal 

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

type PubSubscriberListResponseWrapper 

type PubSubscriberListResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *PubSubscriberListResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

PubSubscriberListApi返回

func (*PubSubscriberListResponseWrapper) Descriptor 

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

func (*PubSubscriberListResponseWrapper) GetCode 

func (m *PubSubscriberListResponseWrapper) GetCode() int32

func (*PubSubscriberListResponseWrapper) GetCodeExplain 

func (m *PubSubscriberListResponseWrapper) GetCodeExplain() string

func (*PubSubscriberListResponseWrapper) GetData 

func (m *PubSubscriberListResponseWrapper) GetData() *PubSubscriberListResponse

func (*PubSubscriberListResponseWrapper) GetError 

func (m *PubSubscriberListResponseWrapper) GetError() string

func (*PubSubscriberListResponseWrapper) ProtoMessage 

func (*PubSubscriberListResponseWrapper) ProtoMessage()

func (*PubSubscriberListResponseWrapper) Reset 

func (m *PubSubscriberListResponseWrapper) Reset()

func (*PubSubscriberListResponseWrapper) String 

func (m *PubSubscriberListResponseWrapper) String() string

func (*PubSubscriberListResponseWrapper) Validate 

func (this *PubSubscriberListResponseWrapper) Validate() error

func (*PubSubscriberListResponseWrapper) XXX_DiscardUnknown 

func (m *PubSubscriberListResponseWrapper) XXX_DiscardUnknown()

func (*PubSubscriberListResponseWrapper) XXX_Marshal 

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

func (*PubSubscriberListResponseWrapper) XXX_Merge 

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

func (*PubSubscriberListResponseWrapper) XXX_Size 

func (m *PubSubscriberListResponseWrapper) XXX_Size() int

func (*PubSubscriberListResponseWrapper) XXX_Unmarshal 

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

type PubSubscriberListResponse_List 

type PubSubscriberListResponse_List struct {
	//
	//订阅的事件列表
	Topics []*notify.Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics" form:"topics"`
	//
	//订阅ID
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	//
	//订阅负责人。如 linus
	Admin string `protobuf:"bytes,4,opt,name=admin,proto3" json:"admin" form:"admin"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,5,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,6,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,7,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//模型修改时间
	Mtime string `protobuf:"bytes,8,opt,name=mtime,proto3" json:"mtime" form:"mtime"`
	//
	//模型版本
	XVersion int32 `protobuf:"varint,9,opt,name=_version,json=Version,proto3" json:"_version" form:"_version"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,10,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubSubscriberListResponse_List) Descriptor 

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

func (*PubSubscriberListResponse_List) GetAdmin 

func (m *PubSubscriberListResponse_List) GetAdmin() string

func (*PubSubscriberListResponse_List) GetCallback 

func (m *PubSubscriberListResponse_List) GetCallback() string

func (*PubSubscriberListResponse_List) GetEnsName 

func (m *PubSubscriberListResponse_List) GetEnsName() string

func (*PubSubscriberListResponse_List) GetInstanceId 

func (m *PubSubscriberListResponse_List) GetInstanceId() string

func (*PubSubscriberListResponse_List) GetMtime 

func (m *PubSubscriberListResponse_List) GetMtime() string

func (*PubSubscriberListResponse_List) GetName 

func (m *PubSubscriberListResponse_List) GetName() string

func (*PubSubscriberListResponse_List) GetRetry 

func (m *PubSubscriberListResponse_List) GetRetry() int32

func (*PubSubscriberListResponse_List) GetTopicVersion 

func (m *PubSubscriberListResponse_List) GetTopicVersion() int32

func (*PubSubscriberListResponse_List) GetTopics 

func (m *PubSubscriberListResponse_List) GetTopics() []*notify.Topic

func (*PubSubscriberListResponse_List) GetXVersion 

func (m *PubSubscriberListResponse_List) GetXVersion() int32

func (*PubSubscriberListResponse_List) ProtoMessage 

func (*PubSubscriberListResponse_List) ProtoMessage()

func (*PubSubscriberListResponse_List) Reset 

func (m *PubSubscriberListResponse_List) Reset()

func (*PubSubscriberListResponse_List) String 

func (m *PubSubscriberListResponse_List) String() string

func (*PubSubscriberListResponse_List) Validate 

func (this *PubSubscriberListResponse_List) Validate() error

func (*PubSubscriberListResponse_List) XXX_DiscardUnknown 

func (m *PubSubscriberListResponse_List) XXX_DiscardUnknown()

func (*PubSubscriberListResponse_List) XXX_Marshal 

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

func (*PubSubscriberListResponse_List) XXX_Merge 

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

func (*PubSubscriberListResponse_List) XXX_Size 

func (m *PubSubscriberListResponse_List) XXX_Size() int

func (*PubSubscriberListResponse_List) XXX_Unmarshal 

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

type PubSubscriberUpdateRequest 

type PubSubscriberUpdateRequest struct {
	//
	//订阅id
	SubscriberId string `protobuf:"bytes,1,opt,name=subscriberId,proto3" json:"subscriberId" form:"subscriberId"`
	//
	//订阅的事件id列表
	Topics []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics" form:"topics"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,4,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,5,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,6,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,7,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberUpdate请求

func (*PubSubscriberUpdateRequest) Descriptor 

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

func (*PubSubscriberUpdateRequest) GetCallback 

func (m *PubSubscriberUpdateRequest) GetCallback() string

func (*PubSubscriberUpdateRequest) GetEnsName 

func (m *PubSubscriberUpdateRequest) GetEnsName() string

func (*PubSubscriberUpdateRequest) GetName 

func (m *PubSubscriberUpdateRequest) GetName() string

func (*PubSubscriberUpdateRequest) GetRetry 

func (m *PubSubscriberUpdateRequest) GetRetry() int32

func (*PubSubscriberUpdateRequest) GetSubscriberId 

func (m *PubSubscriberUpdateRequest) GetSubscriberId() string

func (*PubSubscriberUpdateRequest) GetTopicVersion 

func (m *PubSubscriberUpdateRequest) GetTopicVersion() int32

func (*PubSubscriberUpdateRequest) GetTopics 

func (m *PubSubscriberUpdateRequest) GetTopics() []string

func (*PubSubscriberUpdateRequest) ProtoMessage 

func (*PubSubscriberUpdateRequest) ProtoMessage()

func (*PubSubscriberUpdateRequest) Reset 

func (m *PubSubscriberUpdateRequest) Reset()

func (*PubSubscriberUpdateRequest) String 

func (m *PubSubscriberUpdateRequest) String() string

func (*PubSubscriberUpdateRequest) Validate 

func (this *PubSubscriberUpdateRequest) Validate() error

func (*PubSubscriberUpdateRequest) XXX_DiscardUnknown 

func (m *PubSubscriberUpdateRequest) XXX_DiscardUnknown()

func (*PubSubscriberUpdateRequest) XXX_Marshal 

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

func (*PubSubscriberUpdateRequest) XXX_Merge 

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

func (*PubSubscriberUpdateRequest) XXX_Size 

func (m *PubSubscriberUpdateRequest) XXX_Size() int

func (*PubSubscriberUpdateRequest) XXX_Unmarshal 

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

type PubSubscriberUpdateResponse 

type PubSubscriberUpdateResponse struct {
	//
	//订阅的事件列表
	Topics []*notify.Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics" form:"topics"`
	//
	//订阅ID
	InstanceId string `protobuf:"bytes,2,opt,name=instanceId,proto3" json:"instanceId" form:"instanceId"`
	//
	//订阅名称，可以为中文
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name" form:"name"`
	//
	//订阅负责人。如 linus
	Admin string `protobuf:"bytes,4,opt,name=admin,proto3" json:"admin" form:"admin"`
	//
	//回调url. 处理成功时需要返回 status 2xx
	Callback string `protobuf:"bytes,5,opt,name=callback,proto3" json:"callback" form:"callback"`
	//
	//回调名字服务名。非空时，callback url的域名解析会先经ens
	EnsName string `protobuf:"bytes,6,opt,name=ensName,proto3" json:"ensName" form:"ensName"`
	//
	//retry 为 0 时调用 callback 出错不会重试，否则会无限重试。
	Retry int32 `protobuf:"varint,7,opt,name=retry,proto3" json:"retry" form:"retry"`
	//
	//模型修改时间
	Mtime string `protobuf:"bytes,8,opt,name=mtime,proto3" json:"mtime" form:"mtime"`
	//
	//模型版本
	XVersion int32 `protobuf:"varint,9,opt,name=_version,json=Version,proto3" json:"_version" form:"_version"`
	//
	//订阅的事件的版本，隐藏字段，因为_version不会反应关系的修改
	TopicVersion         int32    `protobuf:"varint,10,opt,name=topicVersion,proto3" json:"topicVersion" form:"topicVersion"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PubSubscriberUpdate返回

func (*PubSubscriberUpdateResponse) Descriptor 

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

func (*PubSubscriberUpdateResponse) GetAdmin 

func (m *PubSubscriberUpdateResponse) GetAdmin() string

func (*PubSubscriberUpdateResponse) GetCallback 

func (m *PubSubscriberUpdateResponse) GetCallback() string

func (*PubSubscriberUpdateResponse) GetEnsName 

func (m *PubSubscriberUpdateResponse) GetEnsName() string

func (*PubSubscriberUpdateResponse) GetInstanceId 

func (m *PubSubscriberUpdateResponse) GetInstanceId() string

func (*PubSubscriberUpdateResponse) GetMtime 

func (m *PubSubscriberUpdateResponse) GetMtime() string

func (*PubSubscriberUpdateResponse) GetName 

func (m *PubSubscriberUpdateResponse) GetName() string

func (*PubSubscriberUpdateResponse) GetRetry 

func (m *PubSubscriberUpdateResponse) GetRetry() int32

func (*PubSubscriberUpdateResponse) GetTopicVersion 

func (m *PubSubscriberUpdateResponse) GetTopicVersion() int32

func (*PubSubscriberUpdateResponse) GetTopics 

func (m *PubSubscriberUpdateResponse) GetTopics() []*notify.Topic

func (*PubSubscriberUpdateResponse) GetXVersion 

func (m *PubSubscriberUpdateResponse) GetXVersion() int32

func (*PubSubscriberUpdateResponse) ProtoMessage 

func (*PubSubscriberUpdateResponse) ProtoMessage()

func (*PubSubscriberUpdateResponse) Reset 

func (m *PubSubscriberUpdateResponse) Reset()

func (*PubSubscriberUpdateResponse) String 

func (m *PubSubscriberUpdateResponse) String() string

func (*PubSubscriberUpdateResponse) Validate 

func (this *PubSubscriberUpdateResponse) Validate() error

func (*PubSubscriberUpdateResponse) XXX_DiscardUnknown 

func (m *PubSubscriberUpdateResponse) XXX_DiscardUnknown()

func (*PubSubscriberUpdateResponse) XXX_Marshal 

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

func (*PubSubscriberUpdateResponse) XXX_Merge 

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

func (*PubSubscriberUpdateResponse) XXX_Size 

func (m *PubSubscriberUpdateResponse) XXX_Size() int

func (*PubSubscriberUpdateResponse) XXX_Unmarshal 

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

type PubSubscriberUpdateResponseWrapper 

type PubSubscriberUpdateResponseWrapper struct {
	//
	//返回码
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code" form:"code"`
	//
	//返回码解释
	CodeExplain string `protobuf:"bytes,2,opt,name=codeExplain,proto3" json:"codeExplain" form:"codeExplain"`
	//
	//错误详情
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" form:"error"`
	//
	//返回数据
	Data                 *PubSubscriberUpdateResponse `protobuf:"bytes,4,opt,name=data,proto3" json:"data" form:"data"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

PubSubscriberUpdateApi返回

func (*PubSubscriberUpdateResponseWrapper) Descriptor 

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

func (*PubSubscriberUpdateResponseWrapper) GetCode 

func (m *PubSubscriberUpdateResponseWrapper) GetCode() int32

func (*PubSubscriberUpdateResponseWrapper) GetCodeExplain 

func (m *PubSubscriberUpdateResponseWrapper) GetCodeExplain() string

func (*PubSubscriberUpdateResponseWrapper) GetData 

func (m *PubSubscriberUpdateResponseWrapper) GetData() *PubSubscriberUpdateResponse

func (*PubSubscriberUpdateResponseWrapper) GetError 

func (m *PubSubscriberUpdateResponseWrapper) GetError() string

func (*PubSubscriberUpdateResponseWrapper) ProtoMessage 

func (*PubSubscriberUpdateResponseWrapper) ProtoMessage()

func (*PubSubscriberUpdateResponseWrapper) Reset 

func (m *PubSubscriberUpdateResponseWrapper) Reset()

func (*PubSubscriberUpdateResponseWrapper) String 

func (m *PubSubscriberUpdateResponseWrapper) String() string

func (*PubSubscriberUpdateResponseWrapper) Validate 

func (this *PubSubscriberUpdateResponseWrapper) Validate() error

func (*PubSubscriberUpdateResponseWrapper) XXX_DiscardUnknown 

func (m *PubSubscriberUpdateResponseWrapper) XXX_DiscardUnknown()

func (*PubSubscriberUpdateResponseWrapper) XXX_Marshal 

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

func (*PubSubscriberUpdateResponseWrapper) XXX_Merge 

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

func (*PubSubscriberUpdateResponseWrapper) XXX_Size 

func (m *PubSubscriberUpdateResponseWrapper) XXX_Size() int

func (*PubSubscriberUpdateResponseWrapper) XXX_Unmarshal 

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

type Service 

type Service interface {
	PubSubscriberCreate(context.Context, *PubSubscriberCreateRequest) (*PubSubscriberCreateResponse, error)
	PubSubscriberDelete(context.Context, *PubSubscriberDeleteRequest) (*types.Empty, error)
	PubSubscriberList(context.Context, *PubSubscriberListRequest) (*PubSubscriberListResponse, error)
	PubSubscriberUpdate(context.Context, *PubSubscriberUpdateRequest) (*PubSubscriberUpdateResponse, error)
}

Service is the server API for subscriber_manager service.

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.