Documentation ¶
Overview ¶
Package mainflux acts as an umbrella package containing multiple different microservices and defines all shared domain concepts.
Index ¶
- Variables
- func Env(key, fallback string) string
- func Health(service string) http.HandlerFunc
- func LoadEnvFile(envfilepath string) error
- func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
- func RegisterThingsServiceServer(s *grpc.Server, srv ThingsServiceServer)
- func RegisterUsersServiceServer(s *grpc.Server, srv UsersServiceServer)
- type AssignRoleReq
- func (*AssignRoleReq) Descriptor() ([]byte, []int)
- func (m *AssignRoleReq) GetId() string
- func (m *AssignRoleReq) GetRole() string
- func (m *AssignRoleReq) Marshal() (dAtA []byte, err error)
- func (m *AssignRoleReq) MarshalTo(dAtA []byte) (int, error)
- func (m *AssignRoleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AssignRoleReq) ProtoMessage()
- func (m *AssignRoleReq) Reset()
- func (m *AssignRoleReq) Size() (n int)
- func (m *AssignRoleReq) String() string
- func (m *AssignRoleReq) Unmarshal(dAtA []byte) error
- func (m *AssignRoleReq) XXX_DiscardUnknown()
- func (m *AssignRoleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AssignRoleReq) XXX_Merge(src proto.Message)
- func (m *AssignRoleReq) XXX_Size() int
- func (m *AssignRoleReq) XXX_Unmarshal(b []byte) error
- type Assignment
- func (*Assignment) Descriptor() ([]byte, []int)
- func (m *Assignment) GetGroupID() string
- func (m *Assignment) GetMemberID() string
- func (m *Assignment) GetToken() string
- func (m *Assignment) Marshal() (dAtA []byte, err error)
- func (m *Assignment) MarshalTo(dAtA []byte) (int, error)
- func (m *Assignment) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Assignment) ProtoMessage()
- func (m *Assignment) Reset()
- func (m *Assignment) Size() (n int)
- func (m *Assignment) String() string
- func (m *Assignment) Unmarshal(dAtA []byte) error
- func (m *Assignment) XXX_DiscardUnknown()
- func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Assignment) XXX_Merge(src proto.Message)
- func (m *Assignment) XXX_Size() int
- func (m *Assignment) XXX_Unmarshal(b []byte) error
- type AuthServiceClient
- type AuthServiceServer
- type AuthorizeReq
- func (*AuthorizeReq) Descriptor() ([]byte, []int)
- func (m *AuthorizeReq) GetAction() string
- func (m *AuthorizeReq) GetObject() string
- func (m *AuthorizeReq) GetSubject() string
- func (m *AuthorizeReq) GetToken() string
- func (m *AuthorizeReq) Marshal() (dAtA []byte, err error)
- func (m *AuthorizeReq) MarshalTo(dAtA []byte) (int, error)
- func (m *AuthorizeReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AuthorizeReq) ProtoMessage()
- func (m *AuthorizeReq) Reset()
- func (m *AuthorizeReq) Size() (n int)
- func (m *AuthorizeReq) String() string
- func (m *AuthorizeReq) Unmarshal(dAtA []byte) error
- func (m *AuthorizeReq) XXX_DiscardUnknown()
- func (m *AuthorizeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthorizeReq) XXX_Merge(src proto.Message)
- func (m *AuthorizeReq) XXX_Size() int
- func (m *AuthorizeReq) XXX_Unmarshal(b []byte) error
- type AuthorizeRes
- func (*AuthorizeRes) Descriptor() ([]byte, []int)
- func (m *AuthorizeRes) GetAuthorized() bool
- func (m *AuthorizeRes) Marshal() (dAtA []byte, err error)
- func (m *AuthorizeRes) MarshalTo(dAtA []byte) (int, error)
- func (m *AuthorizeRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AuthorizeRes) ProtoMessage()
- func (m *AuthorizeRes) Reset()
- func (m *AuthorizeRes) Size() (n int)
- func (m *AuthorizeRes) String() string
- func (m *AuthorizeRes) Unmarshal(dAtA []byte) error
- func (m *AuthorizeRes) XXX_DiscardUnknown()
- func (m *AuthorizeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthorizeRes) XXX_Merge(src proto.Message)
- func (m *AuthorizeRes) XXX_Size() int
- func (m *AuthorizeRes) XXX_Unmarshal(b []byte) error
- type ChannelID
- func (*ChannelID) Descriptor() ([]byte, []int)
- func (m *ChannelID) GetValue() string
- func (m *ChannelID) Marshal() (dAtA []byte, err error)
- func (m *ChannelID) MarshalTo(dAtA []byte) (int, error)
- func (m *ChannelID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChannelID) ProtoMessage()
- func (m *ChannelID) Reset()
- func (m *ChannelID) Size() (n int)
- func (m *ChannelID) String() string
- func (m *ChannelID) Unmarshal(dAtA []byte) error
- func (m *ChannelID) XXX_DiscardUnknown()
- func (m *ChannelID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelID) XXX_Merge(src proto.Message)
- func (m *ChannelID) XXX_Size() int
- func (m *ChannelID) XXX_Unmarshal(b []byte) error
- type ChannelOwnerReq
- func (*ChannelOwnerReq) Descriptor() ([]byte, []int)
- func (m *ChannelOwnerReq) GetChanID() string
- func (m *ChannelOwnerReq) GetToken() string
- func (m *ChannelOwnerReq) Marshal() (dAtA []byte, err error)
- func (m *ChannelOwnerReq) MarshalTo(dAtA []byte) (int, error)
- func (m *ChannelOwnerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChannelOwnerReq) ProtoMessage()
- func (m *ChannelOwnerReq) Reset()
- func (m *ChannelOwnerReq) Size() (n int)
- func (m *ChannelOwnerReq) String() string
- func (m *ChannelOwnerReq) Unmarshal(dAtA []byte) error
- func (m *ChannelOwnerReq) XXX_DiscardUnknown()
- func (m *ChannelOwnerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChannelOwnerReq) XXX_Merge(src proto.Message)
- func (m *ChannelOwnerReq) XXX_Size() int
- func (m *ChannelOwnerReq) XXX_Unmarshal(b []byte) error
- type ConnByKeyReq
- func (*ConnByKeyReq) Descriptor() ([]byte, []int)
- func (m *ConnByKeyReq) GetKey() string
- func (m *ConnByKeyReq) Marshal() (dAtA []byte, err error)
- func (m *ConnByKeyReq) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnByKeyReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnByKeyReq) ProtoMessage()
- func (m *ConnByKeyReq) Reset()
- func (m *ConnByKeyReq) Size() (n int)
- func (m *ConnByKeyReq) String() string
- func (m *ConnByKeyReq) Unmarshal(dAtA []byte) error
- func (m *ConnByKeyReq) XXX_DiscardUnknown()
- func (m *ConnByKeyReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnByKeyReq) XXX_Merge(src proto.Message)
- func (m *ConnByKeyReq) XXX_Size() int
- func (m *ConnByKeyReq) XXX_Unmarshal(b []byte) error
- type ConnByKeyRes
- func (*ConnByKeyRes) Descriptor() ([]byte, []int)
- func (m *ConnByKeyRes) GetChannelID() string
- func (m *ConnByKeyRes) GetProfile() *Profile
- func (m *ConnByKeyRes) GetThingID() string
- func (m *ConnByKeyRes) Marshal() (dAtA []byte, err error)
- func (m *ConnByKeyRes) MarshalTo(dAtA []byte) (int, error)
- func (m *ConnByKeyRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConnByKeyRes) ProtoMessage()
- func (m *ConnByKeyRes) Reset()
- func (m *ConnByKeyRes) Size() (n int)
- func (m *ConnByKeyRes) String() string
- func (m *ConnByKeyRes) Unmarshal(dAtA []byte) error
- func (m *ConnByKeyRes) XXX_DiscardUnknown()
- func (m *ConnByKeyRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConnByKeyRes) XXX_Merge(src proto.Message)
- func (m *ConnByKeyRes) XXX_Size() int
- func (m *ConnByKeyRes) XXX_Unmarshal(b []byte) error
- type Group
- func (*Group) Descriptor() ([]byte, []int)
- func (m *Group) GetDescription() string
- func (m *Group) GetId() string
- func (m *Group) GetName() string
- func (m *Group) GetOwnerID() string
- func (m *Group) Marshal() (dAtA []byte, err error)
- func (m *Group) MarshalTo(dAtA []byte) (int, error)
- func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Group) ProtoMessage()
- func (m *Group) Reset()
- func (m *Group) Size() (n int)
- func (m *Group) String() string
- func (m *Group) Unmarshal(dAtA []byte) error
- func (m *Group) XXX_DiscardUnknown()
- func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Group) XXX_Merge(src proto.Message)
- func (m *Group) XXX_Size() int
- func (m *Group) XXX_Unmarshal(b []byte) error
- type GroupsReq
- func (*GroupsReq) Descriptor() ([]byte, []int)
- func (m *GroupsReq) GetIds() []string
- func (m *GroupsReq) Marshal() (dAtA []byte, err error)
- func (m *GroupsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *GroupsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GroupsReq) ProtoMessage()
- func (m *GroupsReq) Reset()
- func (m *GroupsReq) Size() (n int)
- func (m *GroupsReq) String() string
- func (m *GroupsReq) Unmarshal(dAtA []byte) error
- func (m *GroupsReq) XXX_DiscardUnknown()
- func (m *GroupsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GroupsReq) XXX_Merge(src proto.Message)
- func (m *GroupsReq) XXX_Size() int
- func (m *GroupsReq) XXX_Unmarshal(b []byte) error
- type GroupsRes
- func (*GroupsRes) Descriptor() ([]byte, []int)
- func (m *GroupsRes) GetGroups() []*Group
- func (m *GroupsRes) Marshal() (dAtA []byte, err error)
- func (m *GroupsRes) MarshalTo(dAtA []byte) (int, error)
- func (m *GroupsRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GroupsRes) ProtoMessage()
- func (m *GroupsRes) Reset()
- func (m *GroupsRes) Size() (n int)
- func (m *GroupsRes) String() string
- func (m *GroupsRes) Unmarshal(dAtA []byte) error
- func (m *GroupsRes) XXX_DiscardUnknown()
- func (m *GroupsRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GroupsRes) XXX_Merge(src proto.Message)
- func (m *GroupsRes) XXX_Size() int
- func (m *GroupsRes) XXX_Unmarshal(b []byte) error
- type HealthInfo
- type IDProvider
- type IssueReq
- func (*IssueReq) Descriptor() ([]byte, []int)
- func (m *IssueReq) GetEmail() string
- func (m *IssueReq) GetId() string
- func (m *IssueReq) GetType() uint32
- func (m *IssueReq) Marshal() (dAtA []byte, err error)
- func (m *IssueReq) MarshalTo(dAtA []byte) (int, error)
- func (m *IssueReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IssueReq) ProtoMessage()
- func (m *IssueReq) Reset()
- func (m *IssueReq) Size() (n int)
- func (m *IssueReq) String() string
- func (m *IssueReq) Unmarshal(dAtA []byte) error
- func (m *IssueReq) XXX_DiscardUnknown()
- func (m *IssueReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IssueReq) XXX_Merge(src proto.Message)
- func (m *IssueReq) XXX_Size() int
- func (m *IssueReq) XXX_Unmarshal(b []byte) error
- type MembersReq
- func (*MembersReq) Descriptor() ([]byte, []int)
- func (m *MembersReq) GetGroupID() string
- func (m *MembersReq) GetLimit() uint64
- func (m *MembersReq) GetOffset() uint64
- func (m *MembersReq) GetToken() string
- func (m *MembersReq) GetType() string
- func (m *MembersReq) Marshal() (dAtA []byte, err error)
- func (m *MembersReq) MarshalTo(dAtA []byte) (int, error)
- func (m *MembersReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MembersReq) ProtoMessage()
- func (m *MembersReq) Reset()
- func (m *MembersReq) Size() (n int)
- func (m *MembersReq) String() string
- func (m *MembersReq) Unmarshal(dAtA []byte) error
- func (m *MembersReq) XXX_DiscardUnknown()
- func (m *MembersReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MembersReq) XXX_Merge(src proto.Message)
- func (m *MembersReq) XXX_Size() int
- func (m *MembersReq) XXX_Unmarshal(b []byte) error
- type MembersRes
- func (*MembersRes) Descriptor() ([]byte, []int)
- func (m *MembersRes) GetLimit() uint64
- func (m *MembersRes) GetMembers() []string
- func (m *MembersRes) GetOffset() uint64
- func (m *MembersRes) GetTotal() uint64
- func (m *MembersRes) GetType() string
- func (m *MembersRes) Marshal() (dAtA []byte, err error)
- func (m *MembersRes) MarshalTo(dAtA []byte) (int, error)
- func (m *MembersRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MembersRes) ProtoMessage()
- func (m *MembersRes) Reset()
- func (m *MembersRes) Size() (n int)
- func (m *MembersRes) String() string
- func (m *MembersRes) Unmarshal(dAtA []byte) error
- func (m *MembersRes) XXX_DiscardUnknown()
- func (m *MembersRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MembersRes) XXX_Merge(src proto.Message)
- func (m *MembersRes) XXX_Size() int
- func (m *MembersRes) XXX_Unmarshal(b []byte) error
- type Notifier
- func (*Notifier) Descriptor() ([]byte, []int)
- func (m *Notifier) GetContacts() []string
- func (m *Notifier) GetProtocol() string
- func (m *Notifier) GetSubtopics() []string
- func (m *Notifier) Marshal() (dAtA []byte, err error)
- func (m *Notifier) MarshalTo(dAtA []byte) (int, error)
- func (m *Notifier) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Notifier) ProtoMessage()
- func (m *Notifier) Reset()
- func (m *Notifier) Size() (n int)
- func (m *Notifier) String() string
- func (m *Notifier) Unmarshal(dAtA []byte) error
- func (m *Notifier) XXX_DiscardUnknown()
- func (m *Notifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Notifier) XXX_Merge(src proto.Message)
- func (m *Notifier) XXX_Size() int
- func (m *Notifier) XXX_Unmarshal(b []byte) error
- type PolicyReq
- func (*PolicyReq) Descriptor() ([]byte, []int)
- func (m *PolicyReq) GetObject() string
- func (m *PolicyReq) GetPolicy() string
- func (m *PolicyReq) GetSubject() string
- func (m *PolicyReq) GetToken() string
- func (m *PolicyReq) Marshal() (dAtA []byte, err error)
- func (m *PolicyReq) MarshalTo(dAtA []byte) (int, error)
- func (m *PolicyReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PolicyReq) ProtoMessage()
- func (m *PolicyReq) Reset()
- func (m *PolicyReq) Size() (n int)
- func (m *PolicyReq) String() string
- func (m *PolicyReq) Unmarshal(dAtA []byte) error
- func (m *PolicyReq) XXX_DiscardUnknown()
- func (m *PolicyReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PolicyReq) XXX_Merge(src proto.Message)
- func (m *PolicyReq) XXX_Size() int
- func (m *PolicyReq) XXX_Unmarshal(b []byte) error
- type Profile
- func (*Profile) Descriptor() ([]byte, []int)
- func (m *Profile) GetContentType() string
- func (m *Profile) GetNotifier() *Notifier
- func (m *Profile) GetNotify() bool
- func (m *Profile) GetTransformer() *Transformer
- func (m *Profile) GetWebhook() bool
- func (m *Profile) GetWrite() bool
- func (m *Profile) Marshal() (dAtA []byte, err error)
- func (m *Profile) MarshalTo(dAtA []byte) (int, error)
- func (m *Profile) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Profile) ProtoMessage()
- func (m *Profile) Reset()
- func (m *Profile) Size() (n int)
- func (m *Profile) String() string
- func (m *Profile) Unmarshal(dAtA []byte) error
- func (m *Profile) XXX_DiscardUnknown()
- func (m *Profile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Profile) XXX_Merge(src proto.Message)
- func (m *Profile) XXX_Size() int
- func (m *Profile) XXX_Unmarshal(b []byte) error
- type Response
- type RetrieveRoleReq
- func (*RetrieveRoleReq) Descriptor() ([]byte, []int)
- func (m *RetrieveRoleReq) GetId() string
- func (m *RetrieveRoleReq) Marshal() (dAtA []byte, err error)
- func (m *RetrieveRoleReq) MarshalTo(dAtA []byte) (int, error)
- func (m *RetrieveRoleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RetrieveRoleReq) ProtoMessage()
- func (m *RetrieveRoleReq) Reset()
- func (m *RetrieveRoleReq) Size() (n int)
- func (m *RetrieveRoleReq) String() string
- func (m *RetrieveRoleReq) Unmarshal(dAtA []byte) error
- func (m *RetrieveRoleReq) XXX_DiscardUnknown()
- func (m *RetrieveRoleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RetrieveRoleReq) XXX_Merge(src proto.Message)
- func (m *RetrieveRoleReq) XXX_Size() int
- func (m *RetrieveRoleReq) XXX_Unmarshal(b []byte) error
- type RetrieveRoleRes
- func (*RetrieveRoleRes) Descriptor() ([]byte, []int)
- func (m *RetrieveRoleRes) GetRole() string
- func (m *RetrieveRoleRes) Marshal() (dAtA []byte, err error)
- func (m *RetrieveRoleRes) MarshalTo(dAtA []byte) (int, error)
- func (m *RetrieveRoleRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RetrieveRoleRes) ProtoMessage()
- func (m *RetrieveRoleRes) Reset()
- func (m *RetrieveRoleRes) Size() (n int)
- func (m *RetrieveRoleRes) String() string
- func (m *RetrieveRoleRes) Unmarshal(dAtA []byte) error
- func (m *RetrieveRoleRes) XXX_DiscardUnknown()
- func (m *RetrieveRoleRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RetrieveRoleRes) XXX_Merge(src proto.Message)
- func (m *RetrieveRoleRes) XXX_Size() int
- func (m *RetrieveRoleRes) XXX_Unmarshal(b []byte) error
- type ThingID
- func (*ThingID) Descriptor() ([]byte, []int)
- func (m *ThingID) GetValue() string
- func (m *ThingID) Marshal() (dAtA []byte, err error)
- func (m *ThingID) MarshalTo(dAtA []byte) (int, error)
- func (m *ThingID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ThingID) ProtoMessage()
- func (m *ThingID) Reset()
- func (m *ThingID) Size() (n int)
- func (m *ThingID) String() string
- func (m *ThingID) Unmarshal(dAtA []byte) error
- func (m *ThingID) XXX_DiscardUnknown()
- func (m *ThingID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ThingID) XXX_Merge(src proto.Message)
- func (m *ThingID) XXX_Size() int
- func (m *ThingID) XXX_Unmarshal(b []byte) error
- type ThingOwnerReq
- func (*ThingOwnerReq) Descriptor() ([]byte, []int)
- func (m *ThingOwnerReq) GetThingID() string
- func (m *ThingOwnerReq) GetToken() string
- func (m *ThingOwnerReq) Marshal() (dAtA []byte, err error)
- func (m *ThingOwnerReq) MarshalTo(dAtA []byte) (int, error)
- func (m *ThingOwnerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ThingOwnerReq) ProtoMessage()
- func (m *ThingOwnerReq) Reset()
- func (m *ThingOwnerReq) Size() (n int)
- func (m *ThingOwnerReq) String() string
- func (m *ThingOwnerReq) Unmarshal(dAtA []byte) error
- func (m *ThingOwnerReq) XXX_DiscardUnknown()
- func (m *ThingOwnerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ThingOwnerReq) XXX_Merge(src proto.Message)
- func (m *ThingOwnerReq) XXX_Size() int
- func (m *ThingOwnerReq) XXX_Unmarshal(b []byte) error
- type ThingsServiceClient
- type ThingsServiceServer
- type Token
- func (*Token) Descriptor() ([]byte, []int)
- func (m *Token) GetValue() string
- func (m *Token) Marshal() (dAtA []byte, err error)
- func (m *Token) MarshalTo(dAtA []byte) (int, error)
- func (m *Token) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Token) ProtoMessage()
- func (m *Token) Reset()
- func (m *Token) Size() (n int)
- func (m *Token) String() string
- func (m *Token) Unmarshal(dAtA []byte) error
- func (m *Token) XXX_DiscardUnknown()
- func (m *Token) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Token) XXX_Merge(src proto.Message)
- func (m *Token) XXX_Size() int
- func (m *Token) XXX_Unmarshal(b []byte) error
- type Transformer
- func (*Transformer) Descriptor() ([]byte, []int)
- func (m *Transformer) GetTimeField() string
- func (m *Transformer) GetTimeFormat() string
- func (m *Transformer) GetTimeLocation() string
- func (m *Transformer) GetValueFields() []string
- func (m *Transformer) Marshal() (dAtA []byte, err error)
- func (m *Transformer) MarshalTo(dAtA []byte) (int, error)
- func (m *Transformer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Transformer) ProtoMessage()
- func (m *Transformer) Reset()
- func (m *Transformer) Size() (n int)
- func (m *Transformer) String() string
- func (m *Transformer) Unmarshal(dAtA []byte) error
- func (m *Transformer) XXX_DiscardUnknown()
- func (m *Transformer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Transformer) XXX_Merge(src proto.Message)
- func (m *Transformer) XXX_Size() int
- func (m *Transformer) XXX_Unmarshal(b []byte) error
- type UnimplementedAuthServiceServer
- func (*UnimplementedAuthServiceServer) AddPolicy(ctx context.Context, req *PolicyReq) (*emptypb.Empty, error)
- func (*UnimplementedAuthServiceServer) Assign(ctx context.Context, req *Assignment) (*emptypb.Empty, error)
- func (*UnimplementedAuthServiceServer) AssignRole(ctx context.Context, req *AssignRoleReq) (*emptypb.Empty, error)
- func (*UnimplementedAuthServiceServer) Authorize(ctx context.Context, req *AuthorizeReq) (*emptypb.Empty, error)
- func (*UnimplementedAuthServiceServer) Identify(ctx context.Context, req *Token) (*UserIdentity, error)
- func (*UnimplementedAuthServiceServer) Issue(ctx context.Context, req *IssueReq) (*Token, error)
- func (*UnimplementedAuthServiceServer) Members(ctx context.Context, req *MembersReq) (*MembersRes, error)
- func (*UnimplementedAuthServiceServer) RetrieveRole(ctx context.Context, req *RetrieveRoleReq) (*RetrieveRoleRes, error)
- type UnimplementedThingsServiceServer
- func (*UnimplementedThingsServiceServer) GetConnByKey(ctx context.Context, req *ConnByKeyReq) (*ConnByKeyRes, error)
- func (*UnimplementedThingsServiceServer) GetGroupsByIDs(ctx context.Context, req *GroupsReq) (*GroupsRes, error)
- func (*UnimplementedThingsServiceServer) Identify(ctx context.Context, req *Token) (*ThingID, error)
- func (*UnimplementedThingsServiceServer) IsChannelOwner(ctx context.Context, req *ChannelOwnerReq) (*emptypb.Empty, error)
- func (*UnimplementedThingsServiceServer) IsThingOwner(ctx context.Context, req *ThingOwnerReq) (*emptypb.Empty, error)
- type UnimplementedUsersServiceServer
- type User
- func (*User) Descriptor() ([]byte, []int)
- func (m *User) GetEmail() string
- func (m *User) GetId() string
- func (m *User) GetStatus() string
- func (m *User) Marshal() (dAtA []byte, err error)
- func (m *User) MarshalTo(dAtA []byte) (int, error)
- func (m *User) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*User) ProtoMessage()
- func (m *User) Reset()
- func (m *User) Size() (n int)
- func (m *User) String() string
- func (m *User) Unmarshal(dAtA []byte) error
- func (m *User) XXX_DiscardUnknown()
- func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *User) XXX_Merge(src proto.Message)
- func (m *User) XXX_Size() int
- func (m *User) XXX_Unmarshal(b []byte) error
- type UserIdentity
- func (*UserIdentity) Descriptor() ([]byte, []int)
- func (m *UserIdentity) GetEmail() string
- func (m *UserIdentity) GetId() string
- func (m *UserIdentity) Marshal() (dAtA []byte, err error)
- func (m *UserIdentity) MarshalTo(dAtA []byte) (int, error)
- func (m *UserIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UserIdentity) ProtoMessage()
- func (m *UserIdentity) Reset()
- func (m *UserIdentity) Size() (n int)
- func (m *UserIdentity) String() string
- func (m *UserIdentity) Unmarshal(dAtA []byte) error
- func (m *UserIdentity) XXX_DiscardUnknown()
- func (m *UserIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UserIdentity) XXX_Merge(src proto.Message)
- func (m *UserIdentity) XXX_Size() int
- func (m *UserIdentity) XXX_Unmarshal(b []byte) error
- type UsersByEmailsReq
- func (*UsersByEmailsReq) Descriptor() ([]byte, []int)
- func (m *UsersByEmailsReq) GetEmails() []string
- func (m *UsersByEmailsReq) Marshal() (dAtA []byte, err error)
- func (m *UsersByEmailsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *UsersByEmailsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UsersByEmailsReq) ProtoMessage()
- func (m *UsersByEmailsReq) Reset()
- func (m *UsersByEmailsReq) Size() (n int)
- func (m *UsersByEmailsReq) String() string
- func (m *UsersByEmailsReq) Unmarshal(dAtA []byte) error
- func (m *UsersByEmailsReq) XXX_DiscardUnknown()
- func (m *UsersByEmailsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UsersByEmailsReq) XXX_Merge(src proto.Message)
- func (m *UsersByEmailsReq) XXX_Size() int
- func (m *UsersByEmailsReq) XXX_Unmarshal(b []byte) error
- type UsersByIDsReq
- func (*UsersByIDsReq) Descriptor() ([]byte, []int)
- func (m *UsersByIDsReq) GetIds() []string
- func (m *UsersByIDsReq) Marshal() (dAtA []byte, err error)
- func (m *UsersByIDsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *UsersByIDsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UsersByIDsReq) ProtoMessage()
- func (m *UsersByIDsReq) Reset()
- func (m *UsersByIDsReq) Size() (n int)
- func (m *UsersByIDsReq) String() string
- func (m *UsersByIDsReq) Unmarshal(dAtA []byte) error
- func (m *UsersByIDsReq) XXX_DiscardUnknown()
- func (m *UsersByIDsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UsersByIDsReq) XXX_Merge(src proto.Message)
- func (m *UsersByIDsReq) XXX_Size() int
- func (m *UsersByIDsReq) XXX_Unmarshal(b []byte) error
- type UsersRes
- func (*UsersRes) Descriptor() ([]byte, []int)
- func (m *UsersRes) GetUsers() []*User
- func (m *UsersRes) Marshal() (dAtA []byte, err error)
- func (m *UsersRes) MarshalTo(dAtA []byte) (int, error)
- func (m *UsersRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UsersRes) ProtoMessage()
- func (m *UsersRes) Reset()
- func (m *UsersRes) Size() (n int)
- func (m *UsersRes) String() string
- func (m *UsersRes) Unmarshal(dAtA []byte) error
- func (m *UsersRes) XXX_DiscardUnknown()
- func (m *UsersRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UsersRes) XXX_Merge(src proto.Message)
- func (m *UsersRes) XXX_Size() int
- func (m *UsersRes) XXX_Unmarshal(b []byte) error
- type UsersServiceClient
- type UsersServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthAuth = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAuth = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupAuth = fmt.Errorf("proto: unexpected end of group") )
var ( // Version represents the last service git tag in git history. // It's meant to be set using go build ldflags: // -ldflags "-X 'github.com/MainfluxLabs/mainflux.Version=0.0.0'" Version = "0.0.0" // Commit represents the service git commit hash. // It's meant to be set using go build ldflags: // -ldflags "-X 'github.com/MainfluxLabs/mainflux.Commit=ffffffff'" Commit = "ffffffff" // BuildTime represetns the service build time. // It's meant to be set using go build ldflags: // -ldflags "-X 'github.com/MainfluxLabs/mainflux.BuildTime=1970-01-01_00:00:00'" BuildTime = "1970-01-01_00:00:00" )
Functions ¶
func Env ¶
Env reads specified environment variable. If no value has been found, fallback is returned.
func Health ¶
func Health(service string) http.HandlerFunc
Health exposes an HTTP handler for retrieving service health.
func LoadEnvFile ¶
LoadEnvFile loads environment variables defined in an .env formatted file.
func RegisterAuthServiceServer ¶
func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)
func RegisterThingsServiceServer ¶
func RegisterThingsServiceServer(s *grpc.Server, srv ThingsServiceServer)
func RegisterUsersServiceServer ¶
func RegisterUsersServiceServer(s *grpc.Server, srv UsersServiceServer)
Types ¶
type AssignRoleReq ¶
type AssignRoleReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AssignRoleReq) Descriptor ¶
func (*AssignRoleReq) Descriptor() ([]byte, []int)
func (*AssignRoleReq) GetId ¶
func (m *AssignRoleReq) GetId() string
func (*AssignRoleReq) GetRole ¶
func (m *AssignRoleReq) GetRole() string
func (*AssignRoleReq) Marshal ¶
func (m *AssignRoleReq) Marshal() (dAtA []byte, err error)
func (*AssignRoleReq) MarshalToSizedBuffer ¶
func (m *AssignRoleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AssignRoleReq) ProtoMessage ¶
func (*AssignRoleReq) ProtoMessage()
func (*AssignRoleReq) Reset ¶
func (m *AssignRoleReq) Reset()
func (*AssignRoleReq) Size ¶
func (m *AssignRoleReq) Size() (n int)
func (*AssignRoleReq) String ¶
func (m *AssignRoleReq) String() string
func (*AssignRoleReq) Unmarshal ¶
func (m *AssignRoleReq) Unmarshal(dAtA []byte) error
func (*AssignRoleReq) XXX_DiscardUnknown ¶
func (m *AssignRoleReq) XXX_DiscardUnknown()
func (*AssignRoleReq) XXX_Marshal ¶
func (m *AssignRoleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AssignRoleReq) XXX_Merge ¶
func (m *AssignRoleReq) XXX_Merge(src proto.Message)
func (*AssignRoleReq) XXX_Size ¶
func (m *AssignRoleReq) XXX_Size() int
func (*AssignRoleReq) XXX_Unmarshal ¶
func (m *AssignRoleReq) XXX_Unmarshal(b []byte) error
type Assignment ¶
type Assignment struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` GroupID string `protobuf:"bytes,2,opt,name=groupID,proto3" json:"groupID,omitempty"` MemberID string `protobuf:"bytes,3,opt,name=memberID,proto3" json:"memberID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Assignment) Descriptor ¶
func (*Assignment) Descriptor() ([]byte, []int)
func (*Assignment) GetGroupID ¶
func (m *Assignment) GetGroupID() string
func (*Assignment) GetMemberID ¶
func (m *Assignment) GetMemberID() string
func (*Assignment) GetToken ¶
func (m *Assignment) GetToken() string
func (*Assignment) Marshal ¶
func (m *Assignment) Marshal() (dAtA []byte, err error)
func (*Assignment) MarshalToSizedBuffer ¶
func (m *Assignment) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Assignment) ProtoMessage ¶
func (*Assignment) ProtoMessage()
func (*Assignment) Reset ¶
func (m *Assignment) Reset()
func (*Assignment) Size ¶
func (m *Assignment) Size() (n int)
func (*Assignment) String ¶
func (m *Assignment) String() string
func (*Assignment) Unmarshal ¶
func (m *Assignment) Unmarshal(dAtA []byte) error
func (*Assignment) XXX_DiscardUnknown ¶
func (m *Assignment) XXX_DiscardUnknown()
func (*Assignment) XXX_Marshal ¶
func (m *Assignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Assignment) XXX_Merge ¶
func (m *Assignment) XXX_Merge(src proto.Message)
func (*Assignment) XXX_Size ¶
func (m *Assignment) XXX_Size() int
func (*Assignment) XXX_Unmarshal ¶
func (m *Assignment) XXX_Unmarshal(b []byte) error
type AuthServiceClient ¶
type AuthServiceClient interface { Issue(ctx context.Context, in *IssueReq, opts ...grpc.CallOption) (*Token, error) Identify(ctx context.Context, in *Token, opts ...grpc.CallOption) (*UserIdentity, error) Authorize(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*emptypb.Empty, error) AddPolicy(ctx context.Context, in *PolicyReq, opts ...grpc.CallOption) (*emptypb.Empty, error) Assign(ctx context.Context, in *Assignment, opts ...grpc.CallOption) (*emptypb.Empty, error) Members(ctx context.Context, in *MembersReq, opts ...grpc.CallOption) (*MembersRes, error) AssignRole(ctx context.Context, in *AssignRoleReq, opts ...grpc.CallOption) (*emptypb.Empty, error) RetrieveRole(ctx context.Context, in *RetrieveRoleReq, opts ...grpc.CallOption) (*RetrieveRoleRes, error) }
AuthServiceClient is the client API for AuthService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAuthServiceClient ¶
func NewAuthServiceClient(cc *grpc.ClientConn) AuthServiceClient
type AuthServiceServer ¶
type AuthServiceServer interface { Issue(context.Context, *IssueReq) (*Token, error) Identify(context.Context, *Token) (*UserIdentity, error) Authorize(context.Context, *AuthorizeReq) (*emptypb.Empty, error) AddPolicy(context.Context, *PolicyReq) (*emptypb.Empty, error) Assign(context.Context, *Assignment) (*emptypb.Empty, error) Members(context.Context, *MembersReq) (*MembersRes, error) AssignRole(context.Context, *AssignRoleReq) (*emptypb.Empty, error) RetrieveRole(context.Context, *RetrieveRoleReq) (*RetrieveRoleRes, error) }
AuthServiceServer is the server API for AuthService service.
type AuthorizeReq ¶
type AuthorizeReq struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Object string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"` Subject string `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,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 (*AuthorizeReq) Descriptor ¶
func (*AuthorizeReq) Descriptor() ([]byte, []int)
func (*AuthorizeReq) GetAction ¶
func (m *AuthorizeReq) GetAction() string
func (*AuthorizeReq) GetObject ¶
func (m *AuthorizeReq) GetObject() string
func (*AuthorizeReq) GetSubject ¶
func (m *AuthorizeReq) GetSubject() string
func (*AuthorizeReq) GetToken ¶
func (m *AuthorizeReq) GetToken() string
func (*AuthorizeReq) Marshal ¶
func (m *AuthorizeReq) Marshal() (dAtA []byte, err error)
func (*AuthorizeReq) MarshalToSizedBuffer ¶
func (m *AuthorizeReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AuthorizeReq) ProtoMessage ¶
func (*AuthorizeReq) ProtoMessage()
func (*AuthorizeReq) Reset ¶
func (m *AuthorizeReq) Reset()
func (*AuthorizeReq) Size ¶
func (m *AuthorizeReq) Size() (n int)
func (*AuthorizeReq) String ¶
func (m *AuthorizeReq) String() string
func (*AuthorizeReq) Unmarshal ¶
func (m *AuthorizeReq) Unmarshal(dAtA []byte) error
func (*AuthorizeReq) XXX_DiscardUnknown ¶
func (m *AuthorizeReq) XXX_DiscardUnknown()
func (*AuthorizeReq) XXX_Marshal ¶
func (m *AuthorizeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AuthorizeReq) XXX_Merge ¶
func (m *AuthorizeReq) XXX_Merge(src proto.Message)
func (*AuthorizeReq) XXX_Size ¶
func (m *AuthorizeReq) XXX_Size() int
func (*AuthorizeReq) XXX_Unmarshal ¶
func (m *AuthorizeReq) XXX_Unmarshal(b []byte) error
type AuthorizeRes ¶
type AuthorizeRes struct { Authorized bool `protobuf:"varint,1,opt,name=authorized,proto3" json:"authorized,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AuthorizeRes) Descriptor ¶
func (*AuthorizeRes) Descriptor() ([]byte, []int)
func (*AuthorizeRes) GetAuthorized ¶
func (m *AuthorizeRes) GetAuthorized() bool
func (*AuthorizeRes) Marshal ¶
func (m *AuthorizeRes) Marshal() (dAtA []byte, err error)
func (*AuthorizeRes) MarshalToSizedBuffer ¶
func (m *AuthorizeRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AuthorizeRes) ProtoMessage ¶
func (*AuthorizeRes) ProtoMessage()
func (*AuthorizeRes) Reset ¶
func (m *AuthorizeRes) Reset()
func (*AuthorizeRes) Size ¶
func (m *AuthorizeRes) Size() (n int)
func (*AuthorizeRes) String ¶
func (m *AuthorizeRes) String() string
func (*AuthorizeRes) Unmarshal ¶
func (m *AuthorizeRes) Unmarshal(dAtA []byte) error
func (*AuthorizeRes) XXX_DiscardUnknown ¶
func (m *AuthorizeRes) XXX_DiscardUnknown()
func (*AuthorizeRes) XXX_Marshal ¶
func (m *AuthorizeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AuthorizeRes) XXX_Merge ¶
func (m *AuthorizeRes) XXX_Merge(src proto.Message)
func (*AuthorizeRes) XXX_Size ¶
func (m *AuthorizeRes) XXX_Size() int
func (*AuthorizeRes) XXX_Unmarshal ¶
func (m *AuthorizeRes) XXX_Unmarshal(b []byte) error
type ChannelID ¶
type ChannelID struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelID) Descriptor ¶
func (*ChannelID) MarshalToSizedBuffer ¶
func (*ChannelID) ProtoMessage ¶
func (*ChannelID) ProtoMessage()
func (*ChannelID) XXX_DiscardUnknown ¶
func (m *ChannelID) XXX_DiscardUnknown()
func (*ChannelID) XXX_Marshal ¶
func (*ChannelID) XXX_Unmarshal ¶
type ChannelOwnerReq ¶
type ChannelOwnerReq struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` ChanID string `protobuf:"bytes,2,opt,name=chanID,proto3" json:"chanID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelOwnerReq) Descriptor ¶
func (*ChannelOwnerReq) Descriptor() ([]byte, []int)
func (*ChannelOwnerReq) GetChanID ¶
func (m *ChannelOwnerReq) GetChanID() string
func (*ChannelOwnerReq) GetToken ¶
func (m *ChannelOwnerReq) GetToken() string
func (*ChannelOwnerReq) Marshal ¶
func (m *ChannelOwnerReq) Marshal() (dAtA []byte, err error)
func (*ChannelOwnerReq) MarshalToSizedBuffer ¶
func (m *ChannelOwnerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChannelOwnerReq) ProtoMessage ¶
func (*ChannelOwnerReq) ProtoMessage()
func (*ChannelOwnerReq) Reset ¶
func (m *ChannelOwnerReq) Reset()
func (*ChannelOwnerReq) Size ¶
func (m *ChannelOwnerReq) Size() (n int)
func (*ChannelOwnerReq) String ¶
func (m *ChannelOwnerReq) String() string
func (*ChannelOwnerReq) Unmarshal ¶
func (m *ChannelOwnerReq) Unmarshal(dAtA []byte) error
func (*ChannelOwnerReq) XXX_DiscardUnknown ¶
func (m *ChannelOwnerReq) XXX_DiscardUnknown()
func (*ChannelOwnerReq) XXX_Marshal ¶
func (m *ChannelOwnerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelOwnerReq) XXX_Merge ¶
func (m *ChannelOwnerReq) XXX_Merge(src proto.Message)
func (*ChannelOwnerReq) XXX_Size ¶
func (m *ChannelOwnerReq) XXX_Size() int
func (*ChannelOwnerReq) XXX_Unmarshal ¶
func (m *ChannelOwnerReq) XXX_Unmarshal(b []byte) error
type ConnByKeyReq ¶
type ConnByKeyReq struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnByKeyReq) Descriptor ¶
func (*ConnByKeyReq) Descriptor() ([]byte, []int)
func (*ConnByKeyReq) GetKey ¶
func (m *ConnByKeyReq) GetKey() string
func (*ConnByKeyReq) Marshal ¶
func (m *ConnByKeyReq) Marshal() (dAtA []byte, err error)
func (*ConnByKeyReq) MarshalToSizedBuffer ¶
func (m *ConnByKeyReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnByKeyReq) ProtoMessage ¶
func (*ConnByKeyReq) ProtoMessage()
func (*ConnByKeyReq) Reset ¶
func (m *ConnByKeyReq) Reset()
func (*ConnByKeyReq) Size ¶
func (m *ConnByKeyReq) Size() (n int)
func (*ConnByKeyReq) String ¶
func (m *ConnByKeyReq) String() string
func (*ConnByKeyReq) Unmarshal ¶
func (m *ConnByKeyReq) Unmarshal(dAtA []byte) error
func (*ConnByKeyReq) XXX_DiscardUnknown ¶
func (m *ConnByKeyReq) XXX_DiscardUnknown()
func (*ConnByKeyReq) XXX_Marshal ¶
func (m *ConnByKeyReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnByKeyReq) XXX_Merge ¶
func (m *ConnByKeyReq) XXX_Merge(src proto.Message)
func (*ConnByKeyReq) XXX_Size ¶
func (m *ConnByKeyReq) XXX_Size() int
func (*ConnByKeyReq) XXX_Unmarshal ¶
func (m *ConnByKeyReq) XXX_Unmarshal(b []byte) error
type ConnByKeyRes ¶
type ConnByKeyRes struct { ChannelID string `protobuf:"bytes,1,opt,name=channelID,proto3" json:"channelID,omitempty"` ThingID string `protobuf:"bytes,2,opt,name=thingID,proto3" json:"thingID,omitempty"` Profile *Profile `protobuf:"bytes,3,opt,name=profile,proto3" json:"profile,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ConnByKeyRes) Descriptor ¶
func (*ConnByKeyRes) Descriptor() ([]byte, []int)
func (*ConnByKeyRes) GetChannelID ¶
func (m *ConnByKeyRes) GetChannelID() string
func (*ConnByKeyRes) GetProfile ¶
func (m *ConnByKeyRes) GetProfile() *Profile
func (*ConnByKeyRes) GetThingID ¶
func (m *ConnByKeyRes) GetThingID() string
func (*ConnByKeyRes) Marshal ¶
func (m *ConnByKeyRes) Marshal() (dAtA []byte, err error)
func (*ConnByKeyRes) MarshalToSizedBuffer ¶
func (m *ConnByKeyRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConnByKeyRes) ProtoMessage ¶
func (*ConnByKeyRes) ProtoMessage()
func (*ConnByKeyRes) Reset ¶
func (m *ConnByKeyRes) Reset()
func (*ConnByKeyRes) Size ¶
func (m *ConnByKeyRes) Size() (n int)
func (*ConnByKeyRes) String ¶
func (m *ConnByKeyRes) String() string
func (*ConnByKeyRes) Unmarshal ¶
func (m *ConnByKeyRes) Unmarshal(dAtA []byte) error
func (*ConnByKeyRes) XXX_DiscardUnknown ¶
func (m *ConnByKeyRes) XXX_DiscardUnknown()
func (*ConnByKeyRes) XXX_Marshal ¶
func (m *ConnByKeyRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnByKeyRes) XXX_Merge ¶
func (m *ConnByKeyRes) XXX_Merge(src proto.Message)
func (*ConnByKeyRes) XXX_Size ¶
func (m *ConnByKeyRes) XXX_Size() int
func (*ConnByKeyRes) XXX_Unmarshal ¶
func (m *ConnByKeyRes) XXX_Unmarshal(b []byte) error
type Group ¶
type Group struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` OwnerID string `protobuf:"bytes,2,opt,name=ownerID,proto3" json:"ownerID,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Group) Descriptor ¶
func (*Group) GetDescription ¶
func (*Group) GetOwnerID ¶
func (*Group) MarshalToSizedBuffer ¶
func (*Group) ProtoMessage ¶
func (*Group) ProtoMessage()
func (*Group) XXX_DiscardUnknown ¶
func (m *Group) XXX_DiscardUnknown()
func (*Group) XXX_Marshal ¶
func (*Group) XXX_Unmarshal ¶
type GroupsReq ¶
type GroupsReq struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GroupsReq) Descriptor ¶
func (*GroupsReq) MarshalToSizedBuffer ¶
func (*GroupsReq) ProtoMessage ¶
func (*GroupsReq) ProtoMessage()
func (*GroupsReq) XXX_DiscardUnknown ¶
func (m *GroupsReq) XXX_DiscardUnknown()
func (*GroupsReq) XXX_Marshal ¶
func (*GroupsReq) XXX_Unmarshal ¶
type GroupsRes ¶
type GroupsRes struct { Groups []*Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GroupsRes) Descriptor ¶
func (*GroupsRes) MarshalToSizedBuffer ¶
func (*GroupsRes) ProtoMessage ¶
func (*GroupsRes) ProtoMessage()
func (*GroupsRes) XXX_DiscardUnknown ¶
func (m *GroupsRes) XXX_DiscardUnknown()
func (*GroupsRes) XXX_Marshal ¶
func (*GroupsRes) XXX_Unmarshal ¶
type HealthInfo ¶
type HealthInfo struct { // Status contains service status. Status string `json:"status"` // Version contains current service version. Version string `json:"version"` // Commit represents the git hash commit. Commit string `json:"commit"` // Description contains service description. Description string `json:"description"` // BuildTime contains service build time. BuildTime string `json:"build_time"` }
HealthInfo contains version endpoint response.
type IDProvider ¶
IDProvider specifies an API for generating unique identifiers.
type IssueReq ¶
type IssueReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` Type uint32 `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IssueReq) Descriptor ¶
func (*IssueReq) MarshalToSizedBuffer ¶
func (*IssueReq) ProtoMessage ¶
func (*IssueReq) ProtoMessage()
func (*IssueReq) XXX_DiscardUnknown ¶
func (m *IssueReq) XXX_DiscardUnknown()
func (*IssueReq) XXX_Marshal ¶
func (*IssueReq) XXX_Unmarshal ¶
type MembersReq ¶
type MembersReq struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` GroupID string `protobuf:"bytes,2,opt,name=groupID,proto3" json:"groupID,omitempty"` Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"` Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MembersReq) Descriptor ¶
func (*MembersReq) Descriptor() ([]byte, []int)
func (*MembersReq) GetGroupID ¶
func (m *MembersReq) GetGroupID() string
func (*MembersReq) GetLimit ¶
func (m *MembersReq) GetLimit() uint64
func (*MembersReq) GetOffset ¶
func (m *MembersReq) GetOffset() uint64
func (*MembersReq) GetToken ¶
func (m *MembersReq) GetToken() string
func (*MembersReq) GetType ¶
func (m *MembersReq) GetType() string
func (*MembersReq) Marshal ¶
func (m *MembersReq) Marshal() (dAtA []byte, err error)
func (*MembersReq) MarshalToSizedBuffer ¶
func (m *MembersReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MembersReq) ProtoMessage ¶
func (*MembersReq) ProtoMessage()
func (*MembersReq) Reset ¶
func (m *MembersReq) Reset()
func (*MembersReq) Size ¶
func (m *MembersReq) Size() (n int)
func (*MembersReq) String ¶
func (m *MembersReq) String() string
func (*MembersReq) Unmarshal ¶
func (m *MembersReq) Unmarshal(dAtA []byte) error
func (*MembersReq) XXX_DiscardUnknown ¶
func (m *MembersReq) XXX_DiscardUnknown()
func (*MembersReq) XXX_Marshal ¶
func (m *MembersReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MembersReq) XXX_Merge ¶
func (m *MembersReq) XXX_Merge(src proto.Message)
func (*MembersReq) XXX_Size ¶
func (m *MembersReq) XXX_Size() int
func (*MembersReq) XXX_Unmarshal ¶
func (m *MembersReq) XXX_Unmarshal(b []byte) error
type MembersRes ¶
type MembersRes struct { Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Limit uint64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"` Members []string `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MembersRes) Descriptor ¶
func (*MembersRes) Descriptor() ([]byte, []int)
func (*MembersRes) GetLimit ¶
func (m *MembersRes) GetLimit() uint64
func (*MembersRes) GetMembers ¶
func (m *MembersRes) GetMembers() []string
func (*MembersRes) GetOffset ¶
func (m *MembersRes) GetOffset() uint64
func (*MembersRes) GetTotal ¶
func (m *MembersRes) GetTotal() uint64
func (*MembersRes) GetType ¶
func (m *MembersRes) GetType() string
func (*MembersRes) Marshal ¶
func (m *MembersRes) Marshal() (dAtA []byte, err error)
func (*MembersRes) MarshalToSizedBuffer ¶
func (m *MembersRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MembersRes) ProtoMessage ¶
func (*MembersRes) ProtoMessage()
func (*MembersRes) Reset ¶
func (m *MembersRes) Reset()
func (*MembersRes) Size ¶
func (m *MembersRes) Size() (n int)
func (*MembersRes) String ¶
func (m *MembersRes) String() string
func (*MembersRes) Unmarshal ¶
func (m *MembersRes) Unmarshal(dAtA []byte) error
func (*MembersRes) XXX_DiscardUnknown ¶
func (m *MembersRes) XXX_DiscardUnknown()
func (*MembersRes) XXX_Marshal ¶
func (m *MembersRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MembersRes) XXX_Merge ¶
func (m *MembersRes) XXX_Merge(src proto.Message)
func (*MembersRes) XXX_Size ¶
func (m *MembersRes) XXX_Size() int
func (*MembersRes) XXX_Unmarshal ¶
func (m *MembersRes) XXX_Unmarshal(b []byte) error
type Notifier ¶
type Notifier struct { Protocol string `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"` Subtopics []string `protobuf:"bytes,2,rep,name=subtopics,proto3" json:"subtopics,omitempty"` Contacts []string `protobuf:"bytes,3,rep,name=contacts,proto3" json:"contacts,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Notifier) Descriptor ¶
func (*Notifier) GetContacts ¶
func (*Notifier) GetProtocol ¶
func (*Notifier) GetSubtopics ¶
func (*Notifier) MarshalToSizedBuffer ¶
func (*Notifier) ProtoMessage ¶
func (*Notifier) ProtoMessage()
func (*Notifier) XXX_DiscardUnknown ¶
func (m *Notifier) XXX_DiscardUnknown()
func (*Notifier) XXX_Marshal ¶
func (*Notifier) XXX_Unmarshal ¶
type PolicyReq ¶
type PolicyReq struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` Policy string `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"` Subject string `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"` Object string `protobuf:"bytes,4,opt,name=object,proto3" json:"object,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PolicyReq) Descriptor ¶
func (*PolicyReq) GetSubject ¶
func (*PolicyReq) MarshalToSizedBuffer ¶
func (*PolicyReq) ProtoMessage ¶
func (*PolicyReq) ProtoMessage()
func (*PolicyReq) XXX_DiscardUnknown ¶
func (m *PolicyReq) XXX_DiscardUnknown()
func (*PolicyReq) XXX_Marshal ¶
func (*PolicyReq) XXX_Unmarshal ¶
type Profile ¶
type Profile struct { ContentType string `protobuf:"bytes,1,opt,name=contentType,proto3" json:"contentType,omitempty"` Write bool `protobuf:"varint,2,opt,name=write,proto3" json:"write,omitempty"` Notify bool `protobuf:"varint,3,opt,name=notify,proto3" json:"notify,omitempty"` Webhook bool `protobuf:"varint,4,opt,name=webhook,proto3" json:"webhook,omitempty"` Transformer *Transformer `protobuf:"bytes,5,opt,name=transformer,proto3" json:"transformer,omitempty"` Notifier *Notifier `protobuf:"bytes,6,opt,name=notifier,proto3" json:"notifier,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Profile) Descriptor ¶
func (*Profile) GetContentType ¶
func (*Profile) GetNotifier ¶
func (*Profile) GetTransformer ¶
func (m *Profile) GetTransformer() *Transformer
func (*Profile) GetWebhook ¶
func (*Profile) MarshalToSizedBuffer ¶
func (*Profile) ProtoMessage ¶
func (*Profile) ProtoMessage()
func (*Profile) XXX_DiscardUnknown ¶
func (m *Profile) XXX_DiscardUnknown()
func (*Profile) XXX_Marshal ¶
func (*Profile) XXX_Unmarshal ¶
type Response ¶
type Response interface { // Code returns HTTP response code. Code() int // Headers returns map of HTTP headers with their values. Headers() map[string]string // Empty indicates if HTTP response has content. Empty() bool }
Response contains HTTP response specific methods.
type RetrieveRoleReq ¶
type RetrieveRoleReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RetrieveRoleReq) Descriptor ¶
func (*RetrieveRoleReq) Descriptor() ([]byte, []int)
func (*RetrieveRoleReq) GetId ¶
func (m *RetrieveRoleReq) GetId() string
func (*RetrieveRoleReq) Marshal ¶
func (m *RetrieveRoleReq) Marshal() (dAtA []byte, err error)
func (*RetrieveRoleReq) MarshalToSizedBuffer ¶
func (m *RetrieveRoleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RetrieveRoleReq) ProtoMessage ¶
func (*RetrieveRoleReq) ProtoMessage()
func (*RetrieveRoleReq) Reset ¶
func (m *RetrieveRoleReq) Reset()
func (*RetrieveRoleReq) Size ¶
func (m *RetrieveRoleReq) Size() (n int)
func (*RetrieveRoleReq) String ¶
func (m *RetrieveRoleReq) String() string
func (*RetrieveRoleReq) Unmarshal ¶
func (m *RetrieveRoleReq) Unmarshal(dAtA []byte) error
func (*RetrieveRoleReq) XXX_DiscardUnknown ¶
func (m *RetrieveRoleReq) XXX_DiscardUnknown()
func (*RetrieveRoleReq) XXX_Marshal ¶
func (m *RetrieveRoleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RetrieveRoleReq) XXX_Merge ¶
func (m *RetrieveRoleReq) XXX_Merge(src proto.Message)
func (*RetrieveRoleReq) XXX_Size ¶
func (m *RetrieveRoleReq) XXX_Size() int
func (*RetrieveRoleReq) XXX_Unmarshal ¶
func (m *RetrieveRoleReq) XXX_Unmarshal(b []byte) error
type RetrieveRoleRes ¶
type RetrieveRoleRes struct { Role string `protobuf:"bytes,1,opt,name=role,proto3" json:"role,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RetrieveRoleRes) Descriptor ¶
func (*RetrieveRoleRes) Descriptor() ([]byte, []int)
func (*RetrieveRoleRes) GetRole ¶
func (m *RetrieveRoleRes) GetRole() string
func (*RetrieveRoleRes) Marshal ¶
func (m *RetrieveRoleRes) Marshal() (dAtA []byte, err error)
func (*RetrieveRoleRes) MarshalToSizedBuffer ¶
func (m *RetrieveRoleRes) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RetrieveRoleRes) ProtoMessage ¶
func (*RetrieveRoleRes) ProtoMessage()
func (*RetrieveRoleRes) Reset ¶
func (m *RetrieveRoleRes) Reset()
func (*RetrieveRoleRes) Size ¶
func (m *RetrieveRoleRes) Size() (n int)
func (*RetrieveRoleRes) String ¶
func (m *RetrieveRoleRes) String() string
func (*RetrieveRoleRes) Unmarshal ¶
func (m *RetrieveRoleRes) Unmarshal(dAtA []byte) error
func (*RetrieveRoleRes) XXX_DiscardUnknown ¶
func (m *RetrieveRoleRes) XXX_DiscardUnknown()
func (*RetrieveRoleRes) XXX_Marshal ¶
func (m *RetrieveRoleRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RetrieveRoleRes) XXX_Merge ¶
func (m *RetrieveRoleRes) XXX_Merge(src proto.Message)
func (*RetrieveRoleRes) XXX_Size ¶
func (m *RetrieveRoleRes) XXX_Size() int
func (*RetrieveRoleRes) XXX_Unmarshal ¶
func (m *RetrieveRoleRes) XXX_Unmarshal(b []byte) error
type ThingID ¶
type ThingID struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ThingID) Descriptor ¶
func (*ThingID) MarshalToSizedBuffer ¶
func (*ThingID) ProtoMessage ¶
func (*ThingID) ProtoMessage()
func (*ThingID) XXX_DiscardUnknown ¶
func (m *ThingID) XXX_DiscardUnknown()
func (*ThingID) XXX_Marshal ¶
func (*ThingID) XXX_Unmarshal ¶
type ThingOwnerReq ¶
type ThingOwnerReq struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` ThingID string `protobuf:"bytes,2,opt,name=thingID,proto3" json:"thingID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ThingOwnerReq) Descriptor ¶
func (*ThingOwnerReq) Descriptor() ([]byte, []int)
func (*ThingOwnerReq) GetThingID ¶
func (m *ThingOwnerReq) GetThingID() string
func (*ThingOwnerReq) GetToken ¶
func (m *ThingOwnerReq) GetToken() string
func (*ThingOwnerReq) Marshal ¶
func (m *ThingOwnerReq) Marshal() (dAtA []byte, err error)
func (*ThingOwnerReq) MarshalToSizedBuffer ¶
func (m *ThingOwnerReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ThingOwnerReq) ProtoMessage ¶
func (*ThingOwnerReq) ProtoMessage()
func (*ThingOwnerReq) Reset ¶
func (m *ThingOwnerReq) Reset()
func (*ThingOwnerReq) Size ¶
func (m *ThingOwnerReq) Size() (n int)
func (*ThingOwnerReq) String ¶
func (m *ThingOwnerReq) String() string
func (*ThingOwnerReq) Unmarshal ¶
func (m *ThingOwnerReq) Unmarshal(dAtA []byte) error
func (*ThingOwnerReq) XXX_DiscardUnknown ¶
func (m *ThingOwnerReq) XXX_DiscardUnknown()
func (*ThingOwnerReq) XXX_Marshal ¶
func (m *ThingOwnerReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ThingOwnerReq) XXX_Merge ¶
func (m *ThingOwnerReq) XXX_Merge(src proto.Message)
func (*ThingOwnerReq) XXX_Size ¶
func (m *ThingOwnerReq) XXX_Size() int
func (*ThingOwnerReq) XXX_Unmarshal ¶
func (m *ThingOwnerReq) XXX_Unmarshal(b []byte) error
type ThingsServiceClient ¶
type ThingsServiceClient interface { GetConnByKey(ctx context.Context, in *ConnByKeyReq, opts ...grpc.CallOption) (*ConnByKeyRes, error) IsChannelOwner(ctx context.Context, in *ChannelOwnerReq, opts ...grpc.CallOption) (*emptypb.Empty, error) IsThingOwner(ctx context.Context, in *ThingOwnerReq, opts ...grpc.CallOption) (*emptypb.Empty, error) Identify(ctx context.Context, in *Token, opts ...grpc.CallOption) (*ThingID, error) GetGroupsByIDs(ctx context.Context, in *GroupsReq, opts ...grpc.CallOption) (*GroupsRes, error) }
ThingsServiceClient is the client API for ThingsService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewThingsServiceClient ¶
func NewThingsServiceClient(cc *grpc.ClientConn) ThingsServiceClient
type ThingsServiceServer ¶
type ThingsServiceServer interface { GetConnByKey(context.Context, *ConnByKeyReq) (*ConnByKeyRes, error) IsChannelOwner(context.Context, *ChannelOwnerReq) (*emptypb.Empty, error) IsThingOwner(context.Context, *ThingOwnerReq) (*emptypb.Empty, error) Identify(context.Context, *Token) (*ThingID, error) GetGroupsByIDs(context.Context, *GroupsReq) (*GroupsRes, error) }
ThingsServiceServer is the server API for ThingsService service.
type Token ¶
type Token struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
If a token is not carrying any information itself, the type field can be used to determine how to validate the token. Also, different tokens can be encoded in different ways.
func (*Token) Descriptor ¶
func (*Token) MarshalToSizedBuffer ¶
func (*Token) ProtoMessage ¶
func (*Token) ProtoMessage()
func (*Token) XXX_DiscardUnknown ¶
func (m *Token) XXX_DiscardUnknown()
func (*Token) XXX_Marshal ¶
func (*Token) XXX_Unmarshal ¶
type Transformer ¶
type Transformer struct { ValueFields []string `protobuf:"bytes,1,rep,name=valueFields,proto3" json:"valueFields,omitempty"` TimeField string `protobuf:"bytes,2,opt,name=timeField,proto3" json:"timeField,omitempty"` TimeFormat string `protobuf:"bytes,3,opt,name=timeFormat,proto3" json:"timeFormat,omitempty"` TimeLocation string `protobuf:"bytes,4,opt,name=timeLocation,proto3" json:"timeLocation,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Transformer) Descriptor ¶
func (*Transformer) Descriptor() ([]byte, []int)
func (*Transformer) GetTimeField ¶
func (m *Transformer) GetTimeField() string
func (*Transformer) GetTimeFormat ¶
func (m *Transformer) GetTimeFormat() string
func (*Transformer) GetTimeLocation ¶
func (m *Transformer) GetTimeLocation() string
func (*Transformer) GetValueFields ¶
func (m *Transformer) GetValueFields() []string
func (*Transformer) Marshal ¶
func (m *Transformer) Marshal() (dAtA []byte, err error)
func (*Transformer) MarshalToSizedBuffer ¶
func (m *Transformer) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Transformer) ProtoMessage ¶
func (*Transformer) ProtoMessage()
func (*Transformer) Reset ¶
func (m *Transformer) Reset()
func (*Transformer) Size ¶
func (m *Transformer) Size() (n int)
func (*Transformer) String ¶
func (m *Transformer) String() string
func (*Transformer) Unmarshal ¶
func (m *Transformer) Unmarshal(dAtA []byte) error
func (*Transformer) XXX_DiscardUnknown ¶
func (m *Transformer) XXX_DiscardUnknown()
func (*Transformer) XXX_Marshal ¶
func (m *Transformer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Transformer) XXX_Merge ¶
func (m *Transformer) XXX_Merge(src proto.Message)
func (*Transformer) XXX_Size ¶
func (m *Transformer) XXX_Size() int
func (*Transformer) XXX_Unmarshal ¶
func (m *Transformer) XXX_Unmarshal(b []byte) error
type UnimplementedAuthServiceServer ¶
type UnimplementedAuthServiceServer struct { }
UnimplementedAuthServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedAuthServiceServer) Assign ¶
func (*UnimplementedAuthServiceServer) Assign(ctx context.Context, req *Assignment) (*emptypb.Empty, error)
func (*UnimplementedAuthServiceServer) AssignRole ¶
func (*UnimplementedAuthServiceServer) AssignRole(ctx context.Context, req *AssignRoleReq) (*emptypb.Empty, error)
func (*UnimplementedAuthServiceServer) Authorize ¶
func (*UnimplementedAuthServiceServer) Authorize(ctx context.Context, req *AuthorizeReq) (*emptypb.Empty, error)
func (*UnimplementedAuthServiceServer) Identify ¶
func (*UnimplementedAuthServiceServer) Identify(ctx context.Context, req *Token) (*UserIdentity, error)
func (*UnimplementedAuthServiceServer) Members ¶
func (*UnimplementedAuthServiceServer) Members(ctx context.Context, req *MembersReq) (*MembersRes, error)
func (*UnimplementedAuthServiceServer) RetrieveRole ¶
func (*UnimplementedAuthServiceServer) RetrieveRole(ctx context.Context, req *RetrieveRoleReq) (*RetrieveRoleRes, error)
type UnimplementedThingsServiceServer ¶
type UnimplementedThingsServiceServer struct { }
UnimplementedThingsServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedThingsServiceServer) GetConnByKey ¶
func (*UnimplementedThingsServiceServer) GetConnByKey(ctx context.Context, req *ConnByKeyReq) (*ConnByKeyRes, error)
func (*UnimplementedThingsServiceServer) GetGroupsByIDs ¶
func (*UnimplementedThingsServiceServer) IsChannelOwner ¶
func (*UnimplementedThingsServiceServer) IsChannelOwner(ctx context.Context, req *ChannelOwnerReq) (*emptypb.Empty, error)
func (*UnimplementedThingsServiceServer) IsThingOwner ¶
func (*UnimplementedThingsServiceServer) IsThingOwner(ctx context.Context, req *ThingOwnerReq) (*emptypb.Empty, error)
type UnimplementedUsersServiceServer ¶
type UnimplementedUsersServiceServer struct { }
UnimplementedUsersServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedUsersServiceServer) GetUsersByEmails ¶
func (*UnimplementedUsersServiceServer) GetUsersByEmails(ctx context.Context, req *UsersByEmailsReq) (*UsersRes, error)
func (*UnimplementedUsersServiceServer) GetUsersByIDs ¶
func (*UnimplementedUsersServiceServer) GetUsersByIDs(ctx context.Context, req *UsersByIDsReq) (*UsersRes, error)
type User ¶
type User struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*User) Descriptor ¶
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) XXX_DiscardUnknown ¶
func (m *User) XXX_DiscardUnknown()
func (*User) XXX_Marshal ¶
func (*User) XXX_Unmarshal ¶
type UserIdentity ¶
type UserIdentity struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Email string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UserIdentity) Descriptor ¶
func (*UserIdentity) Descriptor() ([]byte, []int)
func (*UserIdentity) GetEmail ¶
func (m *UserIdentity) GetEmail() string
func (*UserIdentity) GetId ¶
func (m *UserIdentity) GetId() string
func (*UserIdentity) Marshal ¶
func (m *UserIdentity) Marshal() (dAtA []byte, err error)
func (*UserIdentity) MarshalToSizedBuffer ¶
func (m *UserIdentity) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UserIdentity) ProtoMessage ¶
func (*UserIdentity) ProtoMessage()
func (*UserIdentity) Reset ¶
func (m *UserIdentity) Reset()
func (*UserIdentity) Size ¶
func (m *UserIdentity) Size() (n int)
func (*UserIdentity) String ¶
func (m *UserIdentity) String() string
func (*UserIdentity) Unmarshal ¶
func (m *UserIdentity) Unmarshal(dAtA []byte) error
func (*UserIdentity) XXX_DiscardUnknown ¶
func (m *UserIdentity) XXX_DiscardUnknown()
func (*UserIdentity) XXX_Marshal ¶
func (m *UserIdentity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UserIdentity) XXX_Merge ¶
func (m *UserIdentity) XXX_Merge(src proto.Message)
func (*UserIdentity) XXX_Size ¶
func (m *UserIdentity) XXX_Size() int
func (*UserIdentity) XXX_Unmarshal ¶
func (m *UserIdentity) XXX_Unmarshal(b []byte) error
type UsersByEmailsReq ¶
type UsersByEmailsReq struct { Emails []string `protobuf:"bytes,1,rep,name=emails,proto3" json:"emails,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UsersByEmailsReq) Descriptor ¶
func (*UsersByEmailsReq) Descriptor() ([]byte, []int)
func (*UsersByEmailsReq) GetEmails ¶
func (m *UsersByEmailsReq) GetEmails() []string
func (*UsersByEmailsReq) Marshal ¶
func (m *UsersByEmailsReq) Marshal() (dAtA []byte, err error)
func (*UsersByEmailsReq) MarshalTo ¶
func (m *UsersByEmailsReq) MarshalTo(dAtA []byte) (int, error)
func (*UsersByEmailsReq) MarshalToSizedBuffer ¶
func (m *UsersByEmailsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UsersByEmailsReq) ProtoMessage ¶
func (*UsersByEmailsReq) ProtoMessage()
func (*UsersByEmailsReq) Reset ¶
func (m *UsersByEmailsReq) Reset()
func (*UsersByEmailsReq) Size ¶
func (m *UsersByEmailsReq) Size() (n int)
func (*UsersByEmailsReq) String ¶
func (m *UsersByEmailsReq) String() string
func (*UsersByEmailsReq) Unmarshal ¶
func (m *UsersByEmailsReq) Unmarshal(dAtA []byte) error
func (*UsersByEmailsReq) XXX_DiscardUnknown ¶
func (m *UsersByEmailsReq) XXX_DiscardUnknown()
func (*UsersByEmailsReq) XXX_Marshal ¶
func (m *UsersByEmailsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UsersByEmailsReq) XXX_Merge ¶
func (m *UsersByEmailsReq) XXX_Merge(src proto.Message)
func (*UsersByEmailsReq) XXX_Size ¶
func (m *UsersByEmailsReq) XXX_Size() int
func (*UsersByEmailsReq) XXX_Unmarshal ¶
func (m *UsersByEmailsReq) XXX_Unmarshal(b []byte) error
type UsersByIDsReq ¶
type UsersByIDsReq struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UsersByIDsReq) Descriptor ¶
func (*UsersByIDsReq) Descriptor() ([]byte, []int)
func (*UsersByIDsReq) GetIds ¶
func (m *UsersByIDsReq) GetIds() []string
func (*UsersByIDsReq) Marshal ¶
func (m *UsersByIDsReq) Marshal() (dAtA []byte, err error)
func (*UsersByIDsReq) MarshalToSizedBuffer ¶
func (m *UsersByIDsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UsersByIDsReq) ProtoMessage ¶
func (*UsersByIDsReq) ProtoMessage()
func (*UsersByIDsReq) Reset ¶
func (m *UsersByIDsReq) Reset()
func (*UsersByIDsReq) Size ¶
func (m *UsersByIDsReq) Size() (n int)
func (*UsersByIDsReq) String ¶
func (m *UsersByIDsReq) String() string
func (*UsersByIDsReq) Unmarshal ¶
func (m *UsersByIDsReq) Unmarshal(dAtA []byte) error
func (*UsersByIDsReq) XXX_DiscardUnknown ¶
func (m *UsersByIDsReq) XXX_DiscardUnknown()
func (*UsersByIDsReq) XXX_Marshal ¶
func (m *UsersByIDsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UsersByIDsReq) XXX_Merge ¶
func (m *UsersByIDsReq) XXX_Merge(src proto.Message)
func (*UsersByIDsReq) XXX_Size ¶
func (m *UsersByIDsReq) XXX_Size() int
func (*UsersByIDsReq) XXX_Unmarshal ¶
func (m *UsersByIDsReq) XXX_Unmarshal(b []byte) error
type UsersRes ¶
type UsersRes struct { Users []*User `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UsersRes) Descriptor ¶
func (*UsersRes) MarshalToSizedBuffer ¶
func (*UsersRes) ProtoMessage ¶
func (*UsersRes) ProtoMessage()
func (*UsersRes) XXX_DiscardUnknown ¶
func (m *UsersRes) XXX_DiscardUnknown()
func (*UsersRes) XXX_Marshal ¶
func (*UsersRes) XXX_Unmarshal ¶
type UsersServiceClient ¶
type UsersServiceClient interface { GetUsersByIDs(ctx context.Context, in *UsersByIDsReq, opts ...grpc.CallOption) (*UsersRes, error) GetUsersByEmails(ctx context.Context, in *UsersByEmailsReq, opts ...grpc.CallOption) (*UsersRes, error) }
UsersServiceClient is the client API for UsersService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewUsersServiceClient ¶
func NewUsersServiceClient(cc *grpc.ClientConn) UsersServiceClient
type UsersServiceServer ¶
type UsersServiceServer interface { GetUsersByIDs(context.Context, *UsersByIDsReq) (*UsersRes, error) GetUsersByEmails(context.Context, *UsersByEmailsReq) (*UsersRes, error) }
UsersServiceServer is the server API for UsersService service.
Directories ¶
Path | Synopsis |
---|---|
api
Package api contains implementation of Auth service HTTP API.
|
Package api contains implementation of Auth service HTTP API. |
api/grpc
Package grpc contains implementation of Auth service gRPC API.
|
Package grpc contains implementation of Auth service gRPC API. |
postgres
Package postgres contains Key repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains Key repository implementations using PostgreSQL as the underlying database. |
tracing
Package tracing contains middlewares that will add spans to existing traces.
|
Package tracing contains middlewares that will add spans to existing traces. |
Package bootstrap contains the domain concept definitions needed to support Mainflux bootstrap service functionality.
|
Package bootstrap contains the domain concept definitions needed to support Mainflux bootstrap service functionality. |
api
Package api contains implementation of bootstrap service HTTP API.
|
Package api contains implementation of bootstrap service HTTP API. |
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains repository implementations using PostgreSQL as the underlying database. |
redis/consumer
Package consumer contains events consumer for events published by Things service.
|
Package consumer contains events consumer for events published by Things service. |
redis/producer
Package producer contains the domain events needed to support event sourcing of Bootstrap service actions.
|
Package producer contains the domain events needed to support event sourcing of Bootstrap service actions. |
Package certs contains the domain concept definitions needed to support Mainflux certs service functionality.
|
Package certs contains the domain concept definitions needed to support Mainflux certs service functionality. |
api
Package api contains implementation of certs service HTTP API.
|
Package api contains implementation of certs service HTTP API. |
pki
Package pki wraps vault client
|
Package pki wraps vault client |
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains repository implementations using PostgreSQL as the underlying database. |
cmd
|
|
certs
SPDX-License-Identifier: Apache-2.0
|
SPDX-License-Identifier: Apache-2.0 |
Package coap contains the domain concept definitions needed to support Mainflux CoAP adapter service functionality.
|
Package coap contains the domain concept definitions needed to support Mainflux CoAP adapter service functionality. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality.
|
Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality. |
notifiers
Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality.
|
Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality. |
notifiers/smpp
Package smpp contains the domain concept definitions needed to support Mainflux SMS notifications.
|
Package smpp contains the domain concept definitions needed to support Mainflux SMS notifications. |
notifiers/smtp
Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications.
|
Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications. |
writers
Package writers contain the domain concept definitions needed to support Mainflux writer services functionality.
|
Package writers contain the domain concept definitions needed to support Mainflux writer services functionality. |
writers/influxdb
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality.
|
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality. |
writers/mongodb
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality.
|
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality. |
writers/postgres
Package postgres contains repository implementations using Postgres as the underlying database.
|
Package postgres contains repository implementations using Postgres as the underlying database. |
writers/timescale
Package timescale contains repository implementations using Timescale as the underlying database.
|
Package timescale contains repository implementations using Timescale as the underlying database. |
Package http contains the domain concept definitions needed to support Mainflux http adapter service functionality.
|
Package http contains the domain concept definitions needed to support Mainflux http adapter service functionality. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
internal
|
|
Package logger contains logger API definition, wrapper that can be used around any other logger.
|
Package logger contains logger API definition, wrapper that can be used around any other logger. |
api/http
Package http contains implementation of kit service HTTP API.
|
Package http contains implementation of kit service HTTP API. |
redis
Package redis contains cache implementations using Redis as the underlying database.
|
Package redis contains cache implementations using Redis as the underlying database. |
Package pkg contains library packages used by Mainflux services and external services that integrate with Mainflux.
|
Package pkg contains library packages used by Mainflux services and external services that integrate with Mainflux. |
messaging/mqtt
Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the Mainflux IoT platform.
|
Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the Mainflux IoT platform. |
messaging/nats
Package nats hold the implementation of the Publisher and PubSub interfaces for the NATS messaging system, the internal messaging broker of the Mainflux IoT platform.
|
Package nats hold the implementation of the Publisher and PubSub interfaces for the NATS messaging system, the internal messaging broker of the Mainflux IoT platform. |
messaging/rabbitmq
Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the Mainflux IoT platform.
|
Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the Mainflux IoT platform. |
transformers
Package transformers contains the domain concept definitions needed to support Mainflux transformer services functionality.
|
Package transformers contains the domain concept definitions needed to support Mainflux transformer services functionality. |
ulid
Package ulid provides a ULID identity provider.
|
Package ulid provides a ULID identity provider. |
uuid
Package uuid provides a UUID identity provider.
|
Package uuid provides a UUID identity provider. |
Package provision contains domain concept definitions needed to support Provision service feature, i.e.
|
Package provision contains domain concept definitions needed to support Provision service feature, i.e. |
influxdb
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality.
|
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality. |
mongodb
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality.
|
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality. |
postgres
Package postgres contains repository implementations using Postgres as the underlying database.
|
Package postgres contains repository implementations using Postgres as the underlying database. |
timescale
Package timescale contains repository implementations using Timescale as the underlying database.
|
Package timescale contains repository implementations using Timescale as the underlying database. |
Package things contains the domain concept definitions needed to support Mainflux things service functionality.
|
Package things contains the domain concept definitions needed to support Mainflux things service functionality. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
api/grpc
Package grpc contains implementation of things service gRPC API.
|
Package grpc contains implementation of things service gRPC API. |
api/http
Package http contains implementation of things service HTTP API.
|
Package http contains implementation of things service HTTP API. |
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains repository implementations using PostgreSQL as the underlying database. |
redis
Package redis contains cache implementations using Redis as the underlying database.
|
Package redis contains cache implementations using Redis as the underlying database. |
standalone
Package standalone contains implementation for auth service in single-user scenario.
|
Package standalone contains implementation for auth service in single-user scenario. |
tracing
Package tracing contains middlewares that will add spans to existing traces.
|
Package tracing contains middlewares that will add spans to existing traces. |
tools
|
|
api/grpc
Package grpc contains implementation of users service gRPC API.
|
Package grpc contains implementation of users service gRPC API. |
api/http
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
bcrypt
Package bcrypt provides a hasher implementation utilizing bcrypt.
|
Package bcrypt provides a hasher implementation utilizing bcrypt. |
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
|
Package postgres contains repository implementations using PostgreSQL as the underlying database. |
tracing
Package tracing contains middlewares that will add spans to existing traces.
|
Package tracing contains middlewares that will add spans to existing traces. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |
api/http
Package http contains implementation of kit service HTTP API.
|
Package http contains implementation of kit service HTTP API. |
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
|
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations. |