protomfx

package
v0.21.0 Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMfx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMfx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMfx = fmt.Errorf("proto: unexpected end of group")
)

Functions

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 AccessGroupReq 

type AccessGroupReq 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"`
	Action               string   `protobuf:"bytes,3,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AccessGroupReq) Descriptor 

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

func (*AccessGroupReq) GetAction 

func (m *AccessGroupReq) GetAction() string

func (*AccessGroupReq) GetGroupID 

func (m *AccessGroupReq) GetGroupID() string

func (*AccessGroupReq) GetToken 

func (m *AccessGroupReq) GetToken() string

func (*AccessGroupReq) Marshal 

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

func (*AccessGroupReq) MarshalTo 

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

func (*AccessGroupReq) MarshalToSizedBuffer 

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

func (*AccessGroupReq) ProtoMessage 

func (*AccessGroupReq) ProtoMessage()

func (*AccessGroupReq) Reset 

func (m *AccessGroupReq) Reset()

func (*AccessGroupReq) Size 

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

func (*AccessGroupReq) String 

func (m *AccessGroupReq) String() string

func (*AccessGroupReq) Unmarshal 

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

func (*AccessGroupReq) XXX_DiscardUnknown 

func (m *AccessGroupReq) XXX_DiscardUnknown()

func (*AccessGroupReq) XXX_Marshal 

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

func (*AccessGroupReq) XXX_Merge 

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

func (*AccessGroupReq) XXX_Size 

func (m *AccessGroupReq) XXX_Size() int

func (*AccessGroupReq) XXX_Unmarshal 

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

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

func (m *AssignRoleReq) MarshalTo(dAtA []byte) (int, 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 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)
	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)
	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) MarshalTo 

func (m *AuthorizeReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *AuthorizeRes) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*ChannelID) GetValue 

func (m *ChannelID) GetValue() string

func (*ChannelID) Marshal 

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

func (*ChannelID) MarshalTo 

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

func (*ChannelID) MarshalToSizedBuffer 

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

func (*ChannelID) ProtoMessage 

func (*ChannelID) ProtoMessage()

func (*ChannelID) Reset 

func (m *ChannelID) Reset()

func (*ChannelID) Size 

func (m *ChannelID) Size() (n int)

func (*ChannelID) String 

func (m *ChannelID) String() string

func (*ChannelID) Unmarshal 

func (m *ChannelID) Unmarshal(dAtA []byte) error

func (*ChannelID) XXX_DiscardUnknown 

func (m *ChannelID) XXX_DiscardUnknown()

func (*ChannelID) XXX_Marshal 

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

func (*ChannelID) XXX_Merge 

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

func (*ChannelID) XXX_Size 

func (m *ChannelID) XXX_Size() int

func (*ChannelID) XXX_Unmarshal 

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

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

func (m *ChannelOwnerReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ConnByKeyReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ConnByKeyRes) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Group) GetDescription 

func (m *Group) GetDescription() string

func (*Group) GetId 

func (m *Group) GetId() string

func (*Group) GetName 

func (m *Group) GetName() string

func (*Group) GetOwnerID 

func (m *Group) GetOwnerID() string

func (*Group) Marshal 

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

func (*Group) MarshalTo 

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

func (*Group) MarshalToSizedBuffer 

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

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) Size 

func (m *Group) Size() (n int)

func (*Group) String 

func (m *Group) String() string

func (*Group) Unmarshal 

func (m *Group) Unmarshal(dAtA []byte) error

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

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

func (*Group) XXX_Merge 

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

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

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

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

func (*GroupsReq) GetIds 

func (m *GroupsReq) GetIds() []string

func (*GroupsReq) Marshal 

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

func (*GroupsReq) MarshalTo 

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

func (*GroupsReq) MarshalToSizedBuffer 

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

func (*GroupsReq) ProtoMessage 

func (*GroupsReq) ProtoMessage()

func (*GroupsReq) Reset 

func (m *GroupsReq) Reset()

func (*GroupsReq) Size 

func (m *GroupsReq) Size() (n int)

func (*GroupsReq) String 

func (m *GroupsReq) String() string

func (*GroupsReq) Unmarshal 

func (m *GroupsReq) Unmarshal(dAtA []byte) error

func (*GroupsReq) XXX_DiscardUnknown 

func (m *GroupsReq) XXX_DiscardUnknown()

func (*GroupsReq) XXX_Marshal 

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

func (*GroupsReq) XXX_Merge 

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

func (*GroupsReq) XXX_Size 

func (m *GroupsReq) XXX_Size() int

func (*GroupsReq) XXX_Unmarshal 

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

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

func (*GroupsRes) GetGroups 

func (m *GroupsRes) GetGroups() []*Group

func (*GroupsRes) Marshal 

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

func (*GroupsRes) MarshalTo 

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

func (*GroupsRes) MarshalToSizedBuffer 

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

func (*GroupsRes) ProtoMessage 

func (*GroupsRes) ProtoMessage()

func (*GroupsRes) Reset 

func (m *GroupsRes) Reset()

func (*GroupsRes) Size 

func (m *GroupsRes) Size() (n int)

func (*GroupsRes) String 

func (m *GroupsRes) String() string

func (*GroupsRes) Unmarshal 

func (m *GroupsRes) Unmarshal(dAtA []byte) error

func (*GroupsRes) XXX_DiscardUnknown 

func (m *GroupsRes) XXX_DiscardUnknown()

func (*GroupsRes) XXX_Marshal 

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

func (*GroupsRes) XXX_Merge 

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

func (*GroupsRes) XXX_Size 

func (m *GroupsRes) XXX_Size() int

func (*GroupsRes) XXX_Unmarshal 

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

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

func (*IssueReq) GetEmail 

func (m *IssueReq) GetEmail() string

func (*IssueReq) GetId 

func (m *IssueReq) GetId() string

func (*IssueReq) GetType 

func (m *IssueReq) GetType() uint32

func (*IssueReq) Marshal 

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

func (*IssueReq) MarshalTo 

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

func (*IssueReq) MarshalToSizedBuffer 

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

func (*IssueReq) ProtoMessage 

func (*IssueReq) ProtoMessage()

func (*IssueReq) Reset 

func (m *IssueReq) Reset()

func (*IssueReq) Size 

func (m *IssueReq) Size() (n int)

func (*IssueReq) String 

func (m *IssueReq) String() string

func (*IssueReq) Unmarshal 

func (m *IssueReq) Unmarshal(dAtA []byte) error

func (*IssueReq) XXX_DiscardUnknown 

func (m *IssueReq) XXX_DiscardUnknown()

func (*IssueReq) XXX_Marshal 

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

func (*IssueReq) XXX_Merge 

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

func (*IssueReq) XXX_Size 

func (m *IssueReq) XXX_Size() int

func (*IssueReq) XXX_Unmarshal 

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

type Message 

type Message struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Subtopic             string   `protobuf:"bytes,2,opt,name=subtopic,proto3" json:"subtopic,omitempty"`
	Publisher            string   `protobuf:"bytes,3,opt,name=publisher,proto3" json:"publisher,omitempty"`
	Protocol             string   `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Payload              []byte   `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	Created              int64    `protobuf:"varint,6,opt,name=created,proto3" json:"created,omitempty"`
	Profile              *Profile `protobuf:"bytes,7,opt,name=profile,proto3" json:"profile,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetChannel 

func (m *Message) GetChannel() string

func (*Message) GetCreated 

func (m *Message) GetCreated() int64

func (*Message) GetPayload 

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

func (*Message) GetProfile 

func (m *Message) GetProfile() *Profile

func (*Message) GetProtocol 

func (m *Message) GetProtocol() string

func (*Message) GetPublisher 

func (m *Message) GetPublisher() string

func (*Message) GetSubtopic 

func (m *Message) GetSubtopic() string

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) MarshalToSizedBuffer 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

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

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

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

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

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"`
	WebhookID            string       `protobuf:"bytes,3,opt,name=webhookID,proto3" json:"webhookID,omitempty"`
	SmtpID               string       `protobuf:"bytes,4,opt,name=smtpID,proto3" json:"smtpID,omitempty"`
	SmppID               string       `protobuf:"bytes,5,opt,name=smppID,proto3" json:"smppID,omitempty"`
	Transformer          *Transformer `protobuf:"bytes,6,opt,name=transformer,proto3" json:"transformer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Profile) Descriptor 

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

func (*Profile) GetContentType 

func (m *Profile) GetContentType() string

func (*Profile) GetSmppID 

func (m *Profile) GetSmppID() string

func (*Profile) GetSmtpID 

func (m *Profile) GetSmtpID() string

func (*Profile) GetTransformer 

func (m *Profile) GetTransformer() *Transformer

func (*Profile) GetWebhookID 

func (m *Profile) GetWebhookID() string

func (*Profile) GetWrite 

func (m *Profile) GetWrite() bool

func (*Profile) Marshal 

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

func (*Profile) MarshalTo 

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

func (*Profile) MarshalToSizedBuffer 

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

func (*Profile) ProtoMessage 

func (*Profile) ProtoMessage()

func (*Profile) Reset 

func (m *Profile) Reset()

func (*Profile) Size 

func (m *Profile) Size() (n int)

func (*Profile) String 

func (m *Profile) String() string

func (*Profile) Unmarshal 

func (m *Profile) Unmarshal(dAtA []byte) error

func (*Profile) XXX_DiscardUnknown 

func (m *Profile) XXX_DiscardUnknown()

func (*Profile) XXX_Marshal 

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

func (*Profile) XXX_Merge 

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

func (*Profile) XXX_Size 

func (m *Profile) XXX_Size() int

func (*Profile) XXX_Unmarshal 

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

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

func (m *RetrieveRoleReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RetrieveRoleRes) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*ThingID) GetValue 

func (m *ThingID) GetValue() string

func (*ThingID) Marshal 

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

func (*ThingID) MarshalTo 

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

func (*ThingID) MarshalToSizedBuffer 

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

func (*ThingID) ProtoMessage 

func (*ThingID) ProtoMessage()

func (*ThingID) Reset 

func (m *ThingID) Reset()

func (*ThingID) Size 

func (m *ThingID) Size() (n int)

func (*ThingID) String 

func (m *ThingID) String() string

func (*ThingID) Unmarshal 

func (m *ThingID) Unmarshal(dAtA []byte) error

func (*ThingID) XXX_DiscardUnknown 

func (m *ThingID) XXX_DiscardUnknown()

func (*ThingID) XXX_Marshal 

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

func (*ThingID) XXX_Merge 

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

func (*ThingID) XXX_Size 

func (m *ThingID) XXX_Size() int

func (*ThingID) XXX_Unmarshal 

func (m *ThingID) 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)
	CanAccessGroup(ctx context.Context, in *AccessGroupReq, 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)
	CanAccessGroup(context.Context, *AccessGroupReq) (*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) Descriptor() ([]byte, []int)

func (*Token) GetValue 

func (m *Token) GetValue() string

func (*Token) Marshal 

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

func (*Token) MarshalTo 

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

func (*Token) MarshalToSizedBuffer 

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

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) Reset 

func (m *Token) Reset()

func (*Token) Size 

func (m *Token) Size() (n int)

func (*Token) String 

func (m *Token) String() string

func (*Token) Unmarshal 

func (m *Token) Unmarshal(dAtA []byte) error

func (*Token) XXX_DiscardUnknown 

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal 

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

func (*Token) XXX_Merge 

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

func (*Token) XXX_Size 

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal 

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

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

func (m *Transformer) MarshalTo(dAtA []byte) (int, 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) 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) Issue 

func (*UnimplementedAuthServiceServer) Issue(ctx context.Context, req *IssueReq) (*Token, 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) CanAccessGroup 

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

func (*UnimplementedThingsServiceServer) GetConnByKey 

func (*UnimplementedThingsServiceServer) GetConnByKey(ctx context.Context, req *ConnByKeyReq) (*ConnByKeyRes, error)

func (*UnimplementedThingsServiceServer) GetGroupsByIDs 

func (*UnimplementedThingsServiceServer) GetGroupsByIDs(ctx context.Context, req *GroupsReq) (*GroupsRes, error)

func (*UnimplementedThingsServiceServer) Identify 

func (*UnimplementedThingsServiceServer) Identify(ctx context.Context, req *Token) (*ThingID, error)

func (*UnimplementedThingsServiceServer) IsChannelOwner 

func (*UnimplementedThingsServiceServer) IsChannelOwner(ctx context.Context, req *ChannelOwnerReq) (*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) Descriptor() ([]byte, []int)

func (*User) GetEmail 

func (m *User) GetEmail() string

func (*User) GetId 

func (m *User) GetId() string

func (*User) GetStatus 

func (m *User) GetStatus() string

func (*User) Marshal 

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

func (*User) MarshalTo 

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

func (*User) MarshalToSizedBuffer 

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

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) Size 

func (m *User) Size() (n int)

func (*User) String 

func (m *User) String() string

func (*User) Unmarshal 

func (m *User) Unmarshal(dAtA []byte) error

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

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

func (*User) XXX_Merge 

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

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

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

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

func (m *UserIdentity) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *UsersByIDsReq) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*UsersRes) GetUsers 

func (m *UsersRes) GetUsers() []*User

func (*UsersRes) Marshal 

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

func (*UsersRes) MarshalTo 

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

func (*UsersRes) MarshalToSizedBuffer 

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

func (*UsersRes) ProtoMessage 

func (*UsersRes) ProtoMessage()

func (*UsersRes) Reset 

func (m *UsersRes) Reset()

func (*UsersRes) Size 

func (m *UsersRes) Size() (n int)

func (*UsersRes) String 

func (m *UsersRes) String() string

func (*UsersRes) Unmarshal 

func (m *UsersRes) Unmarshal(dAtA []byte) error

func (*UsersRes) XXX_DiscardUnknown 

func (m *UsersRes) XXX_DiscardUnknown()

func (*UsersRes) XXX_Marshal 

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

func (*UsersRes) XXX_Merge 

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

func (*UsersRes) XXX_Size 

func (m *UsersRes) XXX_Size() int

func (*UsersRes) XXX_Unmarshal 

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

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.