protomfx

package

Go to main page

Versions in this module

v0

v0.24.1

Dec 11, 2024

Changes in this version

type Transformer

+ DataField string

+ DataFilters []string

+ func (m *Transformer) GetDataField() string

+ func (m *Transformer) GetDataFilters() []string

v0.24.0

Dec 5, 2024

Changes in this version

+ type Config struct

+ ContentType string

+ SmppID string

+ SmtpID string

+ Transformer *Transformer

+ WebhookID string

+ Write bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Config) ProtoMessage()

+ func (m *Config) GetContentType() string

+ func (m *Config) GetSmppID() string

+ func (m *Config) GetSmtpID() string

+ func (m *Config) GetTransformer() *Transformer

+ func (m *Config) GetWebhookID() string

+ func (m *Config) GetWrite() bool

+ func (m *Config) Marshal() (dAtA []byte, err error)

+ func (m *Config) MarshalTo(dAtA []byte) (int, error)

+ func (m *Config) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Config) Reset()

+ func (m *Config) Size() (n int)

+ func (m *Config) String() string

+ func (m *Config) Unmarshal(dAtA []byte) error

+ func (m *Config) XXX_DiscardUnknown()

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

+ func (m *Config) XXX_Merge(src proto.Message)

+ func (m *Config) XXX_Size() int

+ func (m *Config) XXX_Unmarshal(b []byte) error

+ type ConfigByThingIDRes struct

+ Config *Config

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConfigByThingIDRes) ProtoMessage()

+ func (m *ConfigByThingIDRes) GetConfig() *Config

+ func (m *ConfigByThingIDRes) Marshal() (dAtA []byte, err error)

+ func (m *ConfigByThingIDRes) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigByThingIDRes) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConfigByThingIDRes) Reset()

+ func (m *ConfigByThingIDRes) Size() (n int)

+ func (m *ConfigByThingIDRes) String() string

+ func (m *ConfigByThingIDRes) Unmarshal(dAtA []byte) error

+ func (m *ConfigByThingIDRes) XXX_DiscardUnknown()

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

+ func (m *ConfigByThingIDRes) XXX_Merge(src proto.Message)

+ func (m *ConfigByThingIDRes) XXX_Size() int

+ func (m *ConfigByThingIDRes) XXX_Unmarshal(b []byte) error

type Group

+ OrgID string

+ func (m *Group) GetOrgID() string

type Message

+ ProfileConfig *Config

+ ProfileID string

+ func (m *Message) GetProfileConfig() *Config

+ func (m *Message) GetProfileID() string

+ type PubConfByKeyReq struct

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PubConfByKeyReq) ProtoMessage()

+ func (m *PubConfByKeyReq) GetKey() string

+ func (m *PubConfByKeyReq) Marshal() (dAtA []byte, err error)

+ func (m *PubConfByKeyReq) MarshalTo(dAtA []byte) (int, error)

+ func (m *PubConfByKeyReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubConfByKeyReq) Reset()

+ func (m *PubConfByKeyReq) Size() (n int)

+ func (m *PubConfByKeyReq) String() string

+ func (m *PubConfByKeyReq) Unmarshal(dAtA []byte) error

+ func (m *PubConfByKeyReq) XXX_DiscardUnknown()

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

+ func (m *PubConfByKeyReq) XXX_Merge(src proto.Message)

+ func (m *PubConfByKeyReq) XXX_Size() int

+ func (m *PubConfByKeyReq) XXX_Unmarshal(b []byte) error

+ type PubConfByKeyRes struct

+ ProfileConfig *Config

+ PublisherID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PubConfByKeyRes) ProtoMessage()

+ func (m *PubConfByKeyRes) GetProfileConfig() *Config

+ func (m *PubConfByKeyRes) GetPublisherID() string

+ func (m *PubConfByKeyRes) Marshal() (dAtA []byte, err error)

+ func (m *PubConfByKeyRes) MarshalTo(dAtA []byte) (int, error)

+ func (m *PubConfByKeyRes) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubConfByKeyRes) Reset()

+ func (m *PubConfByKeyRes) Size() (n int)

+ func (m *PubConfByKeyRes) String() string

+ func (m *PubConfByKeyRes) Unmarshal(dAtA []byte) error

+ func (m *PubConfByKeyRes) XXX_DiscardUnknown()

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

+ func (m *PubConfByKeyRes) XXX_Merge(src proto.Message)

+ func (m *PubConfByKeyRes) XXX_Size() int

+ func (m *PubConfByKeyRes) XXX_Unmarshal(b []byte) error

type ThingsServiceClient

+ GetConfigByThingID func(ctx context.Context, in *ThingID, opts ...grpc.CallOption) (*ConfigByThingIDRes, error)

+ GetPubConfByKey func(ctx context.Context, in *PubConfByKeyReq, opts ...grpc.CallOption) (*PubConfByKeyRes, error)

type ThingsServiceServer

+ GetConfigByThingID func(context.Context, *ThingID) (*ConfigByThingIDRes, error)

+ GetPubConfByKey func(context.Context, *PubConfByKeyReq) (*PubConfByKeyRes, error)

type Transformer

+ ValuesFilter []string

+ func (m *Transformer) GetValuesFilter() []string

type UnimplementedThingsServiceServer

+ func (*UnimplementedThingsServiceServer) GetConfigByThingID(ctx context.Context, req *ThingID) (*ConfigByThingIDRes, error)

+ func (*UnimplementedThingsServiceServer) GetPubConfByKey(ctx context.Context, req *PubConfByKeyReq) (*PubConfByKeyRes, error)

v0.23.2

Sep 10, 2024

v0.23.1

Sep 9, 2024

v0.23.0

Sep 3, 2024

v0.22.0

Aug 26, 2024

Changes in this version

+ type GroupID struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GroupID) ProtoMessage()

+ func (m *GroupID) GetValue() string

+ func (m *GroupID) Marshal() (dAtA []byte, err error)

+ func (m *GroupID) MarshalTo(dAtA []byte) (int, error)

+ func (m *GroupID) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GroupID) Reset()

+ func (m *GroupID) Size() (n int)

+ func (m *GroupID) String() string

+ func (m *GroupID) Unmarshal(dAtA []byte) error

+ func (m *GroupID) XXX_DiscardUnknown()

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

+ func (m *GroupID) XXX_Merge(src proto.Message)

+ func (m *GroupID) XXX_Size() int

+ func (m *GroupID) XXX_Unmarshal(b []byte) error

+ type ProfileByThingIDRes struct

+ Profile *Profile

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ProfileByThingIDRes) ProtoMessage()

+ func (m *ProfileByThingIDRes) GetProfile() *Profile

+ func (m *ProfileByThingIDRes) Marshal() (dAtA []byte, err error)

+ func (m *ProfileByThingIDRes) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProfileByThingIDRes) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProfileByThingIDRes) Reset()

+ func (m *ProfileByThingIDRes) Size() (n int)

+ func (m *ProfileByThingIDRes) String() string

+ func (m *ProfileByThingIDRes) Unmarshal(dAtA []byte) error

+ func (m *ProfileByThingIDRes) XXX_DiscardUnknown()

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

+ func (m *ProfileByThingIDRes) XXX_Merge(src proto.Message)

+ func (m *ProfileByThingIDRes) XXX_Size() int

+ func (m *ProfileByThingIDRes) XXX_Unmarshal(b []byte) error

type ThingsServiceClient

+ Authorize func(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetGroupIDByThingID func(ctx context.Context, in *ThingID, opts ...grpc.CallOption) (*GroupID, error)

+ GetProfileByThingID func(ctx context.Context, in *ThingID, opts ...grpc.CallOption) (*ProfileByThingIDRes, error)

type ThingsServiceServer

+ Authorize func(context.Context, *AuthorizeReq) (*emptypb.Empty, error)

+ GetGroupIDByThingID func(context.Context, *ThingID) (*GroupID, error)

+ GetProfileByThingID func(context.Context, *ThingID) (*ProfileByThingIDRes, error)

type UnimplementedThingsServiceServer

+ func (*UnimplementedThingsServiceServer) Authorize(ctx context.Context, req *AuthorizeReq) (*emptypb.Empty, error)

+ func (*UnimplementedThingsServiceServer) GetGroupIDByThingID(ctx context.Context, req *ThingID) (*GroupID, error)

+ func (*UnimplementedThingsServiceServer) GetProfileByThingID(ctx context.Context, req *ThingID) (*ProfileByThingIDRes, error)

v0.21.0

Aug 13, 2024

v0.20.0

Aug 8, 2024

Changes in this version

+ var ErrIntOverflowMfx = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMfx = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupMfx = fmt.Errorf("proto: unexpected end of group")

+ func RegisterAuthServiceServer(s *grpc.Server, srv AuthServiceServer)

+ func RegisterThingsServiceServer(s *grpc.Server, srv ThingsServiceServer)

+ func RegisterUsersServiceServer(s *grpc.Server, srv UsersServiceServer)

+ type AccessGroupReq struct

+ Action string

+ GroupID string

+ Token string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AccessGroupReq) ProtoMessage()

+ func (m *AccessGroupReq) GetAction() string

+ func (m *AccessGroupReq) GetGroupID() string

+ func (m *AccessGroupReq) GetToken() string

+ func (m *AccessGroupReq) Marshal() (dAtA []byte, err error)

+ func (m *AccessGroupReq) MarshalTo(dAtA []byte) (int, error)

+ func (m *AccessGroupReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AccessGroupReq) Reset()

+ func (m *AccessGroupReq) Size() (n int)

+ func (m *AccessGroupReq) String() string

+ func (m *AccessGroupReq) Unmarshal(dAtA []byte) error

+ func (m *AccessGroupReq) XXX_DiscardUnknown()

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

+ func (m *AccessGroupReq) XXX_Merge(src proto.Message)

+ func (m *AccessGroupReq) XXX_Size() int

+ func (m *AccessGroupReq) XXX_Unmarshal(b []byte) error

+ type AssignRoleReq struct

+ Id string

+ Role string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AssignRoleReq) ProtoMessage()

+ 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 (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 AuthServiceClient interface

+ AssignRole func(ctx context.Context, in *AssignRoleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Authorize func(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Identify func(ctx context.Context, in *Token, opts ...grpc.CallOption) (*UserIdentity, error)

+ Issue func(ctx context.Context, in *IssueReq, opts ...grpc.CallOption) (*Token, error)

+ RetrieveRole func(ctx context.Context, in *RetrieveRoleReq, opts ...grpc.CallOption) (*RetrieveRoleRes, error)

+ func NewAuthServiceClient(cc *grpc.ClientConn) AuthServiceClient

+ type AuthServiceServer interface

+ AssignRole func(context.Context, *AssignRoleReq) (*emptypb.Empty, error)

+ Authorize func(context.Context, *AuthorizeReq) (*emptypb.Empty, error)

+ Identify func(context.Context, *Token) (*UserIdentity, error)

+ Issue func(context.Context, *IssueReq) (*Token, error)

+ RetrieveRole func(context.Context, *RetrieveRoleReq) (*RetrieveRoleRes, error)

+ type AuthorizeReq struct

+ Action string

+ Object string

+ Subject string

+ Token string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AuthorizeReq) ProtoMessage()

+ 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 (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 struct

+ Authorized bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*AuthorizeRes) ProtoMessage()

+ 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 (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 struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChannelID) ProtoMessage()

+ 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 (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 struct

+ ChanID string

+ Token string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ChannelOwnerReq) ProtoMessage()

+ 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 (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 struct

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConnByKeyReq) ProtoMessage()

+ 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 (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 struct

+ ChannelID string

+ Profile *Profile

+ ThingID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ConnByKeyRes) ProtoMessage()

+ 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 (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 struct

+ Description string

+ Id string

+ Name string

+ OwnerID string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Group) ProtoMessage()

+ 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 (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 struct

+ Ids []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GroupsReq) ProtoMessage()

+ 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 (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 struct

+ Groups []*Group

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GroupsRes) ProtoMessage()

+ 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 (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 IssueReq struct

+ Email string

+ Id string

+ Type uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*IssueReq) ProtoMessage()

+ 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 (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 Message struct

+ Channel string

+ Created int64

+ Payload []byte

+ Profile *Profile

+ Protocol string

+ Publisher string

+ Subtopic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Message) ProtoMessage()

+ func (m *Message) GetChannel() string

+ func (m *Message) GetCreated() int64

+ func (m *Message) GetPayload() []byte

+ func (m *Message) GetProfile() *Profile

+ func (m *Message) GetProtocol() string

+ func (m *Message) GetPublisher() string

+ func (m *Message) GetSubtopic() string

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ func (m *Message) XXX_DiscardUnknown()

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

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

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ type Profile struct

+ ContentType string

+ SmppID string

+ SmtpID string

+ Transformer *Transformer

+ WebhookID string

+ Write bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Profile) ProtoMessage()

+ func (m *Profile) GetContentType() string

+ func (m *Profile) GetSmppID() string

+ func (m *Profile) GetSmtpID() string

+ func (m *Profile) GetTransformer() *Transformer

+ func (m *Profile) GetWebhookID() string

+ 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 (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 RetrieveRoleReq struct

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RetrieveRoleReq) ProtoMessage()

+ 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 (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 struct

+ Role string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RetrieveRoleRes) ProtoMessage()

+ 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 (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 struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ThingID) ProtoMessage()

+ 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 (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 ThingsServiceClient interface

+ CanAccessGroup func(ctx context.Context, in *AccessGroupReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetConnByKey func(ctx context.Context, in *ConnByKeyReq, opts ...grpc.CallOption) (*ConnByKeyRes, error)

+ GetGroupsByIDs func(ctx context.Context, in *GroupsReq, opts ...grpc.CallOption) (*GroupsRes, error)

+ Identify func(ctx context.Context, in *Token, opts ...grpc.CallOption) (*ThingID, error)

+ IsChannelOwner func(ctx context.Context, in *ChannelOwnerReq, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewThingsServiceClient(cc *grpc.ClientConn) ThingsServiceClient

+ type ThingsServiceServer interface

+ CanAccessGroup func(context.Context, *AccessGroupReq) (*emptypb.Empty, error)

+ GetConnByKey func(context.Context, *ConnByKeyReq) (*ConnByKeyRes, error)

+ GetGroupsByIDs func(context.Context, *GroupsReq) (*GroupsRes, error)

+ Identify func(context.Context, *Token) (*ThingID, error)

+ IsChannelOwner func(context.Context, *ChannelOwnerReq) (*emptypb.Empty, error)

+ type Token struct

+ Value string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Token) ProtoMessage()

+ 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 (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 struct

+ TimeField string

+ TimeFormat string

+ TimeLocation string

+ ValueFields []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Transformer) ProtoMessage()

+ 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 (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 struct

+ 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) RetrieveRole(ctx context.Context, req *RetrieveRoleReq) (*RetrieveRoleRes, error)

+ type UnimplementedThingsServiceServer struct

+ func (*UnimplementedThingsServiceServer) CanAccessGroup(ctx context.Context, req *AccessGroupReq) (*emptypb.Empty, error)

+ 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)

+ type UnimplementedUsersServiceServer struct

+ func (*UnimplementedUsersServiceServer) GetUsersByEmails(ctx context.Context, req *UsersByEmailsReq) (*UsersRes, error)

+ func (*UnimplementedUsersServiceServer) GetUsersByIDs(ctx context.Context, req *UsersByIDsReq) (*UsersRes, error)

+ type User struct

+ Email string

+ Id string

+ Status string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*User) ProtoMessage()

+ 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 (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 struct

+ Email string

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UserIdentity) ProtoMessage()

+ 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 (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 struct

+ Emails []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UsersByEmailsReq) ProtoMessage()

+ 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 (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 struct

+ Ids []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UsersByIDsReq) ProtoMessage()

+ 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 (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 struct

+ Users []*User

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UsersRes) ProtoMessage()

+ 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 (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 interface

+ GetUsersByEmails func(ctx context.Context, in *UsersByEmailsReq, opts ...grpc.CallOption) (*UsersRes, error)

+ GetUsersByIDs func(ctx context.Context, in *UsersByIDsReq, opts ...grpc.CallOption) (*UsersRes, error)

+ func NewUsersServiceClient(cc *grpc.ClientConn) UsersServiceClient

+ type UsersServiceServer interface

+ GetUsersByEmails func(context.Context, *UsersByEmailsReq) (*UsersRes, error)

+ GetUsersByIDs func(context.Context, *UsersByIDsReq) (*UsersRes, error)

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