Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1

package

Go to main page

Versions in this module

v0

v0.4.6

Mar 31, 2022

v0.4.5

Mar 31, 2022

Changes in this version

+ func ErrDefaultSubscribeUnableToModify() errors.Error

+ func ErrForbidden() errors.Error

type Error

+ const Error_ERR_DEFAULT_SUBSCRIBE_UNABLE_TO_MODIFY

+ const Error_ERR_FORBIDDEN

v0.4.4

Mar 28, 2022

v0.4.3

Mar 23, 2022

v0.4.2

Mar 22, 2022

Changes in this version

+ var Error_name = map[int32]string

+ var Error_value = map[string]int32

+ var File_api_subscribe_v1_error_proto protoreflect.FileDescriptor

+ func ErrDeviceNotFound() errors.Error

+ func ErrDuplicateCreate() errors.Error

+ func ErrExist() errors.Error

+ func ErrInternalError() errors.Error

+ func ErrInternalQuery() errors.Error

+ func ErrInvalidArgument() errors.Error

+ func ErrInvalidArgumentSomeFields() errors.Error

+ func ErrList() errors.Error

+ func ErrNotFound() errors.Error

+ func ErrSomeDuplicateCreate() errors.Error

+ func ErrTryToDeleteDefaultSubscribe() errors.Error

+ func ErrUnauthenticated() errors.Error

+ func ErrUnknown() errors.Error

+ type Error int32

+ const Error_ERR_DEVICE_NOT_FOUND

+ const Error_ERR_DUPLICATE_CREATE

+ const Error_ERR_EXIST

+ const Error_ERR_INTERNAL_ERROR

+ const Error_ERR_INTERNAL_QUERY

+ const Error_ERR_INVALID_ARGUMENT

+ const Error_ERR_INVALID_ARGUMENT_SOME_FIELDS

+ const Error_ERR_LIST

+ const Error_ERR_NOT_FOUND

+ const Error_ERR_SOME_DUPLICATE_CREATE

+ const Error_ERR_TRY_TO_DELETE_DEFAULT_SUBSCRIBE

+ const Error_ERR_UNAUTHENTICATED

+ const Error_ERR_UNKNOWN

+ func (Error) Descriptor() protoreflect.EnumDescriptor

+ func (Error) EnumDescriptor() ([]byte, []int)

+ func (Error) Type() protoreflect.EnumType

+ func (x Error) Enum() *Error

+ func (x Error) Number() protoreflect.EnumNumber

+ func (x Error) String() string

v0.4.1

Mar 7, 2022

Changes in this version

+ var File_api_subscribe_v1_subscribe_proto protoreflect.FileDescriptor

+ var Subscribe_ServiceDesc = grpc.ServiceDesc

+ func RegisterSubscribeHTTPServer(container *go_restful.Container, srv SubscribeHTTPServer)

+ func RegisterSubscribeServer(s grpc.ServiceRegistrar, srv SubscribeServer)

+ type ChangeSubscribedRequest struct

+ Id uint64

+ SelectedIds []string

+ TargetId uint64

+ func (*ChangeSubscribedRequest) Descriptor() ([]byte, []int)

+ func (*ChangeSubscribedRequest) ProtoMessage()

+ func (x *ChangeSubscribedRequest) GetId() uint64

+ func (x *ChangeSubscribedRequest) GetSelectedIds() []string

+ func (x *ChangeSubscribedRequest) GetTargetId() uint64

+ func (x *ChangeSubscribedRequest) ProtoReflect() protoreflect.Message

+ func (x *ChangeSubscribedRequest) Reset()

+ func (x *ChangeSubscribedRequest) String() string

+ type ChangeSubscribedResponse struct

+ Status string

+ func (*ChangeSubscribedResponse) Descriptor() ([]byte, []int)

+ func (*ChangeSubscribedResponse) ProtoMessage()

+ func (x *ChangeSubscribedResponse) GetStatus() string

+ func (x *ChangeSubscribedResponse) ProtoReflect() protoreflect.Message

+ func (x *ChangeSubscribedResponse) Reset()

+ func (x *ChangeSubscribedResponse) String() string

+ type CreateSubscribeRequest struct

+ Description string

+ Title string

+ func (*CreateSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*CreateSubscribeRequest) ProtoMessage()

+ func (x *CreateSubscribeRequest) GetDescription() string

+ func (x *CreateSubscribeRequest) GetTitle() string

+ func (x *CreateSubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateSubscribeRequest) Reset()

+ func (x *CreateSubscribeRequest) String() string

+ type CreateSubscribeResponse struct

+ Description string

+ Endpoint string

+ Id uint64

+ IsDefault bool

+ Title string

+ func (*CreateSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*CreateSubscribeResponse) ProtoMessage()

+ func (x *CreateSubscribeResponse) GetDescription() string

+ func (x *CreateSubscribeResponse) GetEndpoint() string

+ func (x *CreateSubscribeResponse) GetId() uint64

+ func (x *CreateSubscribeResponse) GetIsDefault() bool

+ func (x *CreateSubscribeResponse) GetTitle() string

+ func (x *CreateSubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *CreateSubscribeResponse) Reset()

+ func (x *CreateSubscribeResponse) String() string

+ type DeleteSubscribeRequest struct

+ Id uint64

+ func (*DeleteSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*DeleteSubscribeRequest) ProtoMessage()

+ func (x *DeleteSubscribeRequest) GetId() uint64

+ func (x *DeleteSubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteSubscribeRequest) Reset()

+ func (x *DeleteSubscribeRequest) String() string

+ type DeleteSubscribeResponse struct

+ Id uint64

+ func (*DeleteSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*DeleteSubscribeResponse) ProtoMessage()

+ func (x *DeleteSubscribeResponse) GetId() uint64

+ func (x *DeleteSubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteSubscribeResponse) Reset()

+ func (x *DeleteSubscribeResponse) String() string

+ type Entity struct

+ Group string

+ ID string

+ Name string

+ Status string

+ Template string

+ UpdatedAt int64

+ func (*Entity) Descriptor() ([]byte, []int)

+ func (*Entity) ProtoMessage()

+ func (x *Entity) GetGroup() string

+ func (x *Entity) GetID() string

+ func (x *Entity) GetName() string

+ func (x *Entity) GetStatus() string

+ func (x *Entity) GetTemplate() string

+ func (x *Entity) GetUpdatedAt() int64

+ func (x *Entity) ProtoReflect() protoreflect.Message

+ func (x *Entity) Reset()

+ func (x *Entity) String() string

+ type GetSubscribeRequest struct

+ Id uint64

+ func (*GetSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*GetSubscribeRequest) ProtoMessage()

+ func (x *GetSubscribeRequest) GetId() uint64

+ func (x *GetSubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *GetSubscribeRequest) Reset()

+ func (x *GetSubscribeRequest) String() string

+ type GetSubscribeResponse struct

+ Count uint64

+ CreatedAt int64

+ Description string

+ Endpoint string

+ Id uint64

+ IsDefault bool

+ Title string

+ UpdatedAt int64

+ func (*GetSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*GetSubscribeResponse) ProtoMessage()

+ func (x *GetSubscribeResponse) GetCount() uint64

+ func (x *GetSubscribeResponse) GetCreatedAt() int64

+ func (x *GetSubscribeResponse) GetDescription() string

+ func (x *GetSubscribeResponse) GetEndpoint() string

+ func (x *GetSubscribeResponse) GetId() uint64

+ func (x *GetSubscribeResponse) GetIsDefault() bool

+ func (x *GetSubscribeResponse) GetTitle() string

+ func (x *GetSubscribeResponse) GetUpdatedAt() int64

+ func (x *GetSubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *GetSubscribeResponse) Reset()

+ func (x *GetSubscribeResponse) String() string

+ type ListSubscribeEntitiesRequest struct

+ Id uint64

+ IsDescending bool

+ KeyWords string

+ OrderBy string

+ PageNum uint64

+ PageSize uint64

+ SearchKey string

+ func (*ListSubscribeEntitiesRequest) Descriptor() ([]byte, []int)

+ func (*ListSubscribeEntitiesRequest) ProtoMessage()

+ func (x *ListSubscribeEntitiesRequest) GetId() uint64

+ func (x *ListSubscribeEntitiesRequest) GetIsDescending() bool

+ func (x *ListSubscribeEntitiesRequest) GetKeyWords() string

+ func (x *ListSubscribeEntitiesRequest) GetOrderBy() string

+ func (x *ListSubscribeEntitiesRequest) GetPageNum() uint64

+ func (x *ListSubscribeEntitiesRequest) GetPageSize() uint64

+ func (x *ListSubscribeEntitiesRequest) GetSearchKey() string

+ func (x *ListSubscribeEntitiesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSubscribeEntitiesRequest) Reset()

+ func (x *ListSubscribeEntitiesRequest) String() string

+ type ListSubscribeEntitiesResponse struct

+ Data []*Entity

+ LastPage uint64

+ PageNum uint64

+ PageSize uint64

+ Total uint64

+ func (*ListSubscribeEntitiesResponse) Descriptor() ([]byte, []int)

+ func (*ListSubscribeEntitiesResponse) ProtoMessage()

+ func (x *ListSubscribeEntitiesResponse) GetData() []*Entity

+ func (x *ListSubscribeEntitiesResponse) GetLastPage() uint64

+ func (x *ListSubscribeEntitiesResponse) GetPageNum() uint64

+ func (x *ListSubscribeEntitiesResponse) GetPageSize() uint64

+ func (x *ListSubscribeEntitiesResponse) GetTotal() uint64

+ func (x *ListSubscribeEntitiesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSubscribeEntitiesResponse) Reset()

+ func (x *ListSubscribeEntitiesResponse) String() string

+ type ListSubscribeRequest struct

+ IsDescending bool

+ KeyWords string

+ OrderBy string

+ PageNum uint64

+ PageSize uint64

+ SearchKey string

+ func (*ListSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*ListSubscribeRequest) ProtoMessage()

+ func (x *ListSubscribeRequest) GetIsDescending() bool

+ func (x *ListSubscribeRequest) GetKeyWords() string

+ func (x *ListSubscribeRequest) GetOrderBy() string

+ func (x *ListSubscribeRequest) GetPageNum() uint64

+ func (x *ListSubscribeRequest) GetPageSize() uint64

+ func (x *ListSubscribeRequest) GetSearchKey() string

+ func (x *ListSubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *ListSubscribeRequest) Reset()

+ func (x *ListSubscribeRequest) String() string

+ type ListSubscribeResponse struct

+ Data []*SubscribeObject

+ LastPage uint64

+ PageNum uint64

+ PageSize uint64

+ Total uint64

+ func (*ListSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*ListSubscribeResponse) ProtoMessage()

+ func (x *ListSubscribeResponse) GetData() []*SubscribeObject

+ func (x *ListSubscribeResponse) GetLastPage() uint64

+ func (x *ListSubscribeResponse) GetPageNum() uint64

+ func (x *ListSubscribeResponse) GetPageSize() uint64

+ func (x *ListSubscribeResponse) GetTotal() uint64

+ func (x *ListSubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *ListSubscribeResponse) Reset()

+ func (x *ListSubscribeResponse) String() string

+ type SubscribeByDeviceRequest struct

+ Id string

+ SubscribeIds []uint64

+ func (*SubscribeByDeviceRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeByDeviceRequest) ProtoMessage()

+ func (x *SubscribeByDeviceRequest) GetId() string

+ func (x *SubscribeByDeviceRequest) GetSubscribeIds() []uint64

+ func (x *SubscribeByDeviceRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeByDeviceRequest) Reset()

+ func (x *SubscribeByDeviceRequest) String() string

+ type SubscribeByDeviceResponse struct

+ Status string

+ func (*SubscribeByDeviceResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeByDeviceResponse) ProtoMessage()

+ func (x *SubscribeByDeviceResponse) GetStatus() string

+ func (x *SubscribeByDeviceResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeByDeviceResponse) Reset()

+ func (x *SubscribeByDeviceResponse) String() string

+ type SubscribeClient interface

+ ChangeSubscribed func(ctx context.Context, in *ChangeSubscribedRequest, opts ...grpc.CallOption) (*ChangeSubscribedResponse, error)

+ CreateSubscribe func(ctx context.Context, in *CreateSubscribeRequest, opts ...grpc.CallOption) (*CreateSubscribeResponse, error)

+ DeleteSubscribe func(ctx context.Context, in *DeleteSubscribeRequest, opts ...grpc.CallOption) (*DeleteSubscribeResponse, error)

+ GetSubscribe func(ctx context.Context, in *GetSubscribeRequest, opts ...grpc.CallOption) (*GetSubscribeResponse, error)

+ ListSubscribe func(ctx context.Context, in *ListSubscribeRequest, opts ...grpc.CallOption) (*ListSubscribeResponse, error)

+ ListSubscribeEntities func(ctx context.Context, in *ListSubscribeEntitiesRequest, opts ...grpc.CallOption) (*ListSubscribeEntitiesResponse, error)

+ SubscribeByDevice func(ctx context.Context, in *SubscribeByDeviceRequest, opts ...grpc.CallOption) (*SubscribeByDeviceResponse, error)

+ SubscribeEntitiesByGroups func(ctx context.Context, in *SubscribeEntitiesByGroupsRequest, ...) (*SubscribeEntitiesByGroupsResponse, error)

+ SubscribeEntitiesByIDs func(ctx context.Context, in *SubscribeEntitiesByIDsRequest, ...) (*SubscribeEntitiesByIDsResponse, error)

+ SubscribeEntitiesByModels func(ctx context.Context, in *SubscribeEntitiesByModelsRequest, ...) (*SubscribeEntitiesByModelsResponse, error)

+ UnsubscribeEntitiesByIDs func(ctx context.Context, in *UnsubscribeEntitiesByIDsRequest, ...) (*UnsubscribeEntitiesByIDsResponse, error)

+ UpdateSubscribe func(ctx context.Context, in *UpdateSubscribeRequest, opts ...grpc.CallOption) (*UpdateSubscribeResponse, error)

+ ValidateSubscribed func(ctx context.Context, in *ValidateSubscribedRequest, opts ...grpc.CallOption) (*ValidateSubscribedResponse, error)

+ func NewSubscribeClient(cc grpc.ClientConnInterface) SubscribeClient

+ type SubscribeEntitiesByGroupsRequest struct

+ Groups []string

+ Id uint64

+ func (*SubscribeEntitiesByGroupsRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByGroupsRequest) ProtoMessage()

+ func (x *SubscribeEntitiesByGroupsRequest) GetGroups() []string

+ func (x *SubscribeEntitiesByGroupsRequest) GetId() uint64

+ func (x *SubscribeEntitiesByGroupsRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByGroupsRequest) Reset()

+ func (x *SubscribeEntitiesByGroupsRequest) String() string

+ type SubscribeEntitiesByGroupsResponse struct

+ Id uint64

+ Status string

+ func (*SubscribeEntitiesByGroupsResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByGroupsResponse) ProtoMessage()

+ func (x *SubscribeEntitiesByGroupsResponse) GetId() uint64

+ func (x *SubscribeEntitiesByGroupsResponse) GetStatus() string

+ func (x *SubscribeEntitiesByGroupsResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByGroupsResponse) Reset()

+ func (x *SubscribeEntitiesByGroupsResponse) String() string

+ type SubscribeEntitiesByIDsRequest struct

+ Entities []string

+ Id uint64

+ func (*SubscribeEntitiesByIDsRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByIDsRequest) ProtoMessage()

+ func (x *SubscribeEntitiesByIDsRequest) GetEntities() []string

+ func (x *SubscribeEntitiesByIDsRequest) GetId() uint64

+ func (x *SubscribeEntitiesByIDsRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByIDsRequest) Reset()

+ func (x *SubscribeEntitiesByIDsRequest) String() string

+ type SubscribeEntitiesByIDsResponse struct

+ Id uint64

+ Status string

+ func (*SubscribeEntitiesByIDsResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByIDsResponse) ProtoMessage()

+ func (x *SubscribeEntitiesByIDsResponse) GetId() uint64

+ func (x *SubscribeEntitiesByIDsResponse) GetStatus() string

+ func (x *SubscribeEntitiesByIDsResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByIDsResponse) Reset()

+ func (x *SubscribeEntitiesByIDsResponse) String() string

+ type SubscribeEntitiesByModelsRequest struct

+ Id uint64

+ Models []string

+ func (*SubscribeEntitiesByModelsRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByModelsRequest) ProtoMessage()

+ func (x *SubscribeEntitiesByModelsRequest) GetId() uint64

+ func (x *SubscribeEntitiesByModelsRequest) GetModels() []string

+ func (x *SubscribeEntitiesByModelsRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByModelsRequest) Reset()

+ func (x *SubscribeEntitiesByModelsRequest) String() string

+ type SubscribeEntitiesByModelsResponse struct

+ Id uint64

+ Status string

+ func (*SubscribeEntitiesByModelsResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeEntitiesByModelsResponse) ProtoMessage()

+ func (x *SubscribeEntitiesByModelsResponse) GetId() uint64

+ func (x *SubscribeEntitiesByModelsResponse) GetStatus() string

+ func (x *SubscribeEntitiesByModelsResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeEntitiesByModelsResponse) Reset()

+ func (x *SubscribeEntitiesByModelsResponse) String() string

+ type SubscribeHTTPHandler struct

+ func (h *SubscribeHTTPHandler) ChangeSubscribed(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) CreateSubscribe(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) DeleteSubscribe(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) GetSubscribe(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) ListSubscribe(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) ListSubscribeEntities(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) SubscribeByDevice(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) SubscribeEntitiesByGroups(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) SubscribeEntitiesByIDs(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) SubscribeEntitiesByModels(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) UnsubscribeEntitiesByIDs(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) UpdateSubscribe(req *go_restful.Request, resp *go_restful.Response)

+ func (h *SubscribeHTTPHandler) ValidateSubscribed(req *go_restful.Request, resp *go_restful.Response)

+ type SubscribeHTTPServer interface

+ ChangeSubscribed func(context.Context, *ChangeSubscribedRequest) (*ChangeSubscribedResponse, error)

+ CreateSubscribe func(context.Context, *CreateSubscribeRequest) (*CreateSubscribeResponse, error)

+ DeleteSubscribe func(context.Context, *DeleteSubscribeRequest) (*DeleteSubscribeResponse, error)

+ GetSubscribe func(context.Context, *GetSubscribeRequest) (*GetSubscribeResponse, error)

+ ListSubscribe func(context.Context, *ListSubscribeRequest) (*ListSubscribeResponse, error)

+ ListSubscribeEntities func(context.Context, *ListSubscribeEntitiesRequest) (*ListSubscribeEntitiesResponse, error)

+ SubscribeByDevice func(context.Context, *SubscribeByDeviceRequest) (*SubscribeByDeviceResponse, error)

+ SubscribeEntitiesByGroups func(context.Context, *SubscribeEntitiesByGroupsRequest) (*SubscribeEntitiesByGroupsResponse, error)

+ SubscribeEntitiesByIDs func(context.Context, *SubscribeEntitiesByIDsRequest) (*SubscribeEntitiesByIDsResponse, error)

+ SubscribeEntitiesByModels func(context.Context, *SubscribeEntitiesByModelsRequest) (*SubscribeEntitiesByModelsResponse, error)

+ UnsubscribeEntitiesByIDs func(context.Context, *UnsubscribeEntitiesByIDsRequest) (*UnsubscribeEntitiesByIDsResponse, error)

+ UpdateSubscribe func(context.Context, *UpdateSubscribeRequest) (*UpdateSubscribeResponse, error)

+ ValidateSubscribed func(context.Context, *ValidateSubscribedRequest) (*ValidateSubscribedResponse, error)

+ type SubscribeObject struct

+ Description string

+ Endpoint string

+ Id uint64

+ IsDefault bool

+ Title string

+ func (*SubscribeObject) Descriptor() ([]byte, []int)

+ func (*SubscribeObject) ProtoMessage()

+ func (x *SubscribeObject) GetDescription() string

+ func (x *SubscribeObject) GetEndpoint() string

+ func (x *SubscribeObject) GetId() uint64

+ func (x *SubscribeObject) GetIsDefault() bool

+ func (x *SubscribeObject) GetTitle() string

+ func (x *SubscribeObject) ProtoReflect() protoreflect.Message

+ func (x *SubscribeObject) Reset()

+ func (x *SubscribeObject) String() string

+ type SubscribeServer interface

+ ChangeSubscribed func(context.Context, *ChangeSubscribedRequest) (*ChangeSubscribedResponse, error)

+ CreateSubscribe func(context.Context, *CreateSubscribeRequest) (*CreateSubscribeResponse, error)

+ DeleteSubscribe func(context.Context, *DeleteSubscribeRequest) (*DeleteSubscribeResponse, error)

+ GetSubscribe func(context.Context, *GetSubscribeRequest) (*GetSubscribeResponse, error)

+ ListSubscribe func(context.Context, *ListSubscribeRequest) (*ListSubscribeResponse, error)

+ ListSubscribeEntities func(context.Context, *ListSubscribeEntitiesRequest) (*ListSubscribeEntitiesResponse, error)

+ SubscribeByDevice func(context.Context, *SubscribeByDeviceRequest) (*SubscribeByDeviceResponse, error)

+ SubscribeEntitiesByGroups func(context.Context, *SubscribeEntitiesByGroupsRequest) (*SubscribeEntitiesByGroupsResponse, error)

+ SubscribeEntitiesByIDs func(context.Context, *SubscribeEntitiesByIDsRequest) (*SubscribeEntitiesByIDsResponse, error)

+ SubscribeEntitiesByModels func(context.Context, *SubscribeEntitiesByModelsRequest) (*SubscribeEntitiesByModelsResponse, error)

+ UnsubscribeEntitiesByIDs func(context.Context, *UnsubscribeEntitiesByIDsRequest) (*UnsubscribeEntitiesByIDsResponse, error)

+ UpdateSubscribe func(context.Context, *UpdateSubscribeRequest) (*UpdateSubscribeResponse, error)

+ ValidateSubscribed func(context.Context, *ValidateSubscribedRequest) (*ValidateSubscribedResponse, error)

+ type UnimplementedSubscribeServer struct

+ func (UnimplementedSubscribeServer) ChangeSubscribed(context.Context, *ChangeSubscribedRequest) (*ChangeSubscribedResponse, error)

+ func (UnimplementedSubscribeServer) CreateSubscribe(context.Context, *CreateSubscribeRequest) (*CreateSubscribeResponse, error)

+ func (UnimplementedSubscribeServer) DeleteSubscribe(context.Context, *DeleteSubscribeRequest) (*DeleteSubscribeResponse, error)

+ func (UnimplementedSubscribeServer) GetSubscribe(context.Context, *GetSubscribeRequest) (*GetSubscribeResponse, error)

+ func (UnimplementedSubscribeServer) ListSubscribe(context.Context, *ListSubscribeRequest) (*ListSubscribeResponse, error)

+ func (UnimplementedSubscribeServer) ListSubscribeEntities(context.Context, *ListSubscribeEntitiesRequest) (*ListSubscribeEntitiesResponse, error)

+ func (UnimplementedSubscribeServer) SubscribeByDevice(context.Context, *SubscribeByDeviceRequest) (*SubscribeByDeviceResponse, error)

+ func (UnimplementedSubscribeServer) SubscribeEntitiesByGroups(context.Context, *SubscribeEntitiesByGroupsRequest) (*SubscribeEntitiesByGroupsResponse, error)

+ func (UnimplementedSubscribeServer) SubscribeEntitiesByIDs(context.Context, *SubscribeEntitiesByIDsRequest) (*SubscribeEntitiesByIDsResponse, error)

+ func (UnimplementedSubscribeServer) SubscribeEntitiesByModels(context.Context, *SubscribeEntitiesByModelsRequest) (*SubscribeEntitiesByModelsResponse, error)

+ func (UnimplementedSubscribeServer) UnsubscribeEntitiesByIDs(context.Context, *UnsubscribeEntitiesByIDsRequest) (*UnsubscribeEntitiesByIDsResponse, error)

+ func (UnimplementedSubscribeServer) UpdateSubscribe(context.Context, *UpdateSubscribeRequest) (*UpdateSubscribeResponse, error)

+ func (UnimplementedSubscribeServer) ValidateSubscribed(context.Context, *ValidateSubscribedRequest) (*ValidateSubscribedResponse, error)

+ type UnsafeSubscribeServer interface

+ type UnsubscribeEntitiesByIDsRequest struct

+ Entities []string

+ Id uint64

+ func (*UnsubscribeEntitiesByIDsRequest) Descriptor() ([]byte, []int)

+ func (*UnsubscribeEntitiesByIDsRequest) ProtoMessage()

+ func (x *UnsubscribeEntitiesByIDsRequest) GetEntities() []string

+ func (x *UnsubscribeEntitiesByIDsRequest) GetId() uint64

+ func (x *UnsubscribeEntitiesByIDsRequest) ProtoReflect() protoreflect.Message

+ func (x *UnsubscribeEntitiesByIDsRequest) Reset()

+ func (x *UnsubscribeEntitiesByIDsRequest) String() string

+ type UnsubscribeEntitiesByIDsResponse struct

+ Id uint64

+ Status string

+ func (*UnsubscribeEntitiesByIDsResponse) Descriptor() ([]byte, []int)

+ func (*UnsubscribeEntitiesByIDsResponse) ProtoMessage()

+ func (x *UnsubscribeEntitiesByIDsResponse) GetId() uint64

+ func (x *UnsubscribeEntitiesByIDsResponse) GetStatus() string

+ func (x *UnsubscribeEntitiesByIDsResponse) ProtoReflect() protoreflect.Message

+ func (x *UnsubscribeEntitiesByIDsResponse) Reset()

+ func (x *UnsubscribeEntitiesByIDsResponse) String() string

+ type UpdateSubscribeRequest struct

+ Description string

+ Id uint64

+ Title string

+ func (*UpdateSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*UpdateSubscribeRequest) ProtoMessage()

+ func (x *UpdateSubscribeRequest) GetDescription() string

+ func (x *UpdateSubscribeRequest) GetId() uint64

+ func (x *UpdateSubscribeRequest) GetTitle() string

+ func (x *UpdateSubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateSubscribeRequest) Reset()

+ func (x *UpdateSubscribeRequest) String() string

+ type UpdateSubscribeResponse struct

+ Description string

+ Endpoint string

+ Id uint64

+ IsDefault bool

+ Title string

+ func (*UpdateSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*UpdateSubscribeResponse) ProtoMessage()

+ func (x *UpdateSubscribeResponse) GetDescription() string

+ func (x *UpdateSubscribeResponse) GetEndpoint() string

+ func (x *UpdateSubscribeResponse) GetId() uint64

+ func (x *UpdateSubscribeResponse) GetIsDefault() bool

+ func (x *UpdateSubscribeResponse) GetTitle() string

+ func (x *UpdateSubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *UpdateSubscribeResponse) Reset()

+ func (x *UpdateSubscribeResponse) String() string

+ type ValidateSubscribedRequest struct

+ Topic string

+ func (*ValidateSubscribedRequest) Descriptor() ([]byte, []int)

+ func (*ValidateSubscribedRequest) ProtoMessage()

+ func (x *ValidateSubscribedRequest) GetTopic() string

+ func (x *ValidateSubscribedRequest) ProtoReflect() protoreflect.Message

+ func (x *ValidateSubscribedRequest) Reset()

+ func (x *ValidateSubscribedRequest) String() string

+ type ValidateSubscribedResponse struct

+ Status string

+ func (*ValidateSubscribedResponse) Descriptor() ([]byte, []int)

+ func (*ValidateSubscribedResponse) ProtoMessage()

+ func (x *ValidateSubscribedResponse) GetStatus() string

+ func (x *ValidateSubscribedResponse) ProtoReflect() protoreflect.Message

+ func (x *ValidateSubscribedResponse) Reset()

+ func (x *ValidateSubscribedResponse) String() string