protomfx

package
v0.33.0 Latest Latest
Warning

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

 Go to latest Published: Nov 28, 2025 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 RegisterRulesServiceServer added in v0.28.0 

func RegisterRulesServiceServer(s *grpc.Server, srv RulesServiceServer)

func RegisterThingsServiceServer 

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

func RegisterUsersServiceServer 

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

Types

type ActivateOrgInviteReq added in v0.31.1 

type ActivateOrgInviteReq struct {
	PlatformInviteID     string   `protobuf:"bytes,1,opt,name=platformInviteID,proto3" json:"platformInviteID,omitempty"`
	UserID               string   `protobuf:"bytes,2,opt,name=userID,proto3" json:"userID,omitempty"`
	RedirectPath         string   `protobuf:"bytes,3,opt,name=redirectPath,proto3" json:"redirectPath,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateOrgInviteReq) Descriptor added in v0.31.1 

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

func (*ActivateOrgInviteReq) GetPlatformInviteID added in v0.31.1 

func (m *ActivateOrgInviteReq) GetPlatformInviteID() string

func (*ActivateOrgInviteReq) GetRedirectPath added in v0.31.1 

func (m *ActivateOrgInviteReq) GetRedirectPath() string

func (*ActivateOrgInviteReq) GetUserID added in v0.31.1 

func (m *ActivateOrgInviteReq) GetUserID() string

func (*ActivateOrgInviteReq) Marshal added in v0.31.1 

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

func (*ActivateOrgInviteReq) MarshalTo added in v0.31.1 

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

func (*ActivateOrgInviteReq) MarshalToSizedBuffer added in v0.31.1 

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

func (*ActivateOrgInviteReq) ProtoMessage added in v0.31.1 

func (*ActivateOrgInviteReq) ProtoMessage()

func (*ActivateOrgInviteReq) Reset added in v0.31.1 

func (m *ActivateOrgInviteReq) Reset()

func (*ActivateOrgInviteReq) Size added in v0.31.1 

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

func (*ActivateOrgInviteReq) String added in v0.31.1 

func (m *ActivateOrgInviteReq) String() string

func (*ActivateOrgInviteReq) Unmarshal added in v0.31.1 

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

func (*ActivateOrgInviteReq) XXX_DiscardUnknown added in v0.31.1 

func (m *ActivateOrgInviteReq) XXX_DiscardUnknown()

func (*ActivateOrgInviteReq) XXX_Marshal added in v0.31.1 

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

func (*ActivateOrgInviteReq) XXX_Merge added in v0.31.1 

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

func (*ActivateOrgInviteReq) XXX_Size added in v0.31.1 

func (m *ActivateOrgInviteReq) XXX_Size() int

func (*ActivateOrgInviteReq) XXX_Unmarshal added in v0.31.1 

func (m *ActivateOrgInviteReq) 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)
	GetOwnerIDByOrgID(ctx context.Context, in *OrgID, opts ...grpc.CallOption) (*OwnerID, error)
	AssignRole(ctx context.Context, in *AssignRoleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RetrieveRole(ctx context.Context, in *RetrieveRoleReq, opts ...grpc.CallOption) (*RetrieveRoleRes, error)
	CreateDormantOrgInvite(ctx context.Context, in *CreateDormantOrgInviteReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ActivateOrgInvite(ctx context.Context, in *ActivateOrgInviteReq, opts ...grpc.CallOption) (*emptypb.Empty, 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)
	GetOwnerIDByOrgID(context.Context, *OrgID) (*OwnerID, error)
	AssignRole(context.Context, *AssignRoleReq) (*emptypb.Empty, error)
	RetrieveRole(context.Context, *RetrieveRoleReq) (*RetrieveRoleRes, error)
	CreateDormantOrgInvite(context.Context, *CreateDormantOrgInviteReq) (*emptypb.Empty, error)
	ActivateOrgInvite(context.Context, *ActivateOrgInviteReq) (*emptypb.Empty, 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 Config added in v0.24.0 

type Config struct {
	ContentType          string       `protobuf:"bytes,1,opt,name=contentType,proto3" json:"contentType,omitempty"`
	Transformer          *Transformer `protobuf:"bytes,2,opt,name=transformer,proto3" json:"transformer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Config) Descriptor added in v0.24.0 

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

func (*Config) GetContentType added in v0.24.0 

func (m *Config) GetContentType() string

func (*Config) GetTransformer added in v0.24.0 

func (m *Config) GetTransformer() *Transformer

func (*Config) Marshal added in v0.24.0 

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

func (*Config) MarshalTo added in v0.24.0 

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

func (*Config) MarshalToSizedBuffer added in v0.24.0 

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

func (*Config) ProtoMessage added in v0.24.0 

func (*Config) ProtoMessage()

func (*Config) Reset added in v0.24.0 

func (m *Config) Reset()

func (*Config) Size added in v0.24.0 

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

func (*Config) String added in v0.24.0 

func (m *Config) String() string

func (*Config) Unmarshal added in v0.24.0 

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

func (*Config) XXX_DiscardUnknown added in v0.24.0 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal added in v0.24.0 

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

func (*Config) XXX_Merge added in v0.24.0 

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

func (*Config) XXX_Size added in v0.24.0 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal added in v0.24.0 

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

type ConfigByThingIDRes added in v0.24.0 

type ConfigByThingIDRes struct {
	Config               *Config  `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigByThingIDRes) Descriptor added in v0.24.0 

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

func (*ConfigByThingIDRes) GetConfig added in v0.24.0 

func (m *ConfigByThingIDRes) GetConfig() *Config

func (*ConfigByThingIDRes) Marshal added in v0.24.0 

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

func (*ConfigByThingIDRes) MarshalTo added in v0.24.0 

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

func (*ConfigByThingIDRes) MarshalToSizedBuffer added in v0.24.0 

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

func (*ConfigByThingIDRes) ProtoMessage added in v0.24.0 

func (*ConfigByThingIDRes) ProtoMessage()

func (*ConfigByThingIDRes) Reset added in v0.24.0 

func (m *ConfigByThingIDRes) Reset()

func (*ConfigByThingIDRes) Size added in v0.24.0 

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

func (*ConfigByThingIDRes) String added in v0.24.0 

func (m *ConfigByThingIDRes) String() string

func (*ConfigByThingIDRes) Unmarshal added in v0.24.0 

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

func (*ConfigByThingIDRes) XXX_DiscardUnknown added in v0.24.0 

func (m *ConfigByThingIDRes) XXX_DiscardUnknown()

func (*ConfigByThingIDRes) XXX_Marshal added in v0.24.0 

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

func (*ConfigByThingIDRes) XXX_Merge added in v0.24.0 

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

func (*ConfigByThingIDRes) XXX_Size added in v0.24.0 

func (m *ConfigByThingIDRes) XXX_Size() int

func (*ConfigByThingIDRes) XXX_Unmarshal added in v0.24.0 

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

type CreateDormantOrgInviteReq added in v0.31.1 

type CreateDormantOrgInviteReq struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	OrgID                string   `protobuf:"bytes,2,opt,name=orgID,proto3" json:"orgID,omitempty"`
	InviteeRole          string   `protobuf:"bytes,3,opt,name=inviteeRole,proto3" json:"inviteeRole,omitempty"`
	PlatformInviteID     string   `protobuf:"bytes,4,opt,name=platformInviteID,proto3" json:"platformInviteID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDormantOrgInviteReq) Descriptor added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) GetInviteeRole added in v0.31.1 

func (m *CreateDormantOrgInviteReq) GetInviteeRole() string

func (*CreateDormantOrgInviteReq) GetOrgID added in v0.31.1 

func (m *CreateDormantOrgInviteReq) GetOrgID() string

func (*CreateDormantOrgInviteReq) GetPlatformInviteID added in v0.31.1 

func (m *CreateDormantOrgInviteReq) GetPlatformInviteID() string

func (*CreateDormantOrgInviteReq) GetToken added in v0.31.1 

func (m *CreateDormantOrgInviteReq) GetToken() string

func (*CreateDormantOrgInviteReq) Marshal added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) MarshalTo added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) MarshalToSizedBuffer added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) ProtoMessage added in v0.31.1 

func (*CreateDormantOrgInviteReq) ProtoMessage()

func (*CreateDormantOrgInviteReq) Reset added in v0.31.1 

func (m *CreateDormantOrgInviteReq) Reset()

func (*CreateDormantOrgInviteReq) Size added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) String added in v0.31.1 

func (m *CreateDormantOrgInviteReq) String() string

func (*CreateDormantOrgInviteReq) Unmarshal added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) XXX_DiscardUnknown added in v0.31.1 

func (m *CreateDormantOrgInviteReq) XXX_DiscardUnknown()

func (*CreateDormantOrgInviteReq) XXX_Marshal added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) XXX_Merge added in v0.31.1 

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

func (*CreateDormantOrgInviteReq) XXX_Size added in v0.31.1 

func (m *CreateDormantOrgInviteReq) XXX_Size() int

func (*CreateDormantOrgInviteReq) XXX_Unmarshal added in v0.31.1 

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

type GroupID added in v0.22.0 

type GroupID 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 (*GroupID) Descriptor added in v0.22.0 

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

func (*GroupID) GetValue added in v0.22.0 

func (m *GroupID) GetValue() string

func (*GroupID) Marshal added in v0.22.0 

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

func (*GroupID) MarshalTo added in v0.22.0 

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

func (*GroupID) MarshalToSizedBuffer added in v0.22.0 

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

func (*GroupID) ProtoMessage added in v0.22.0 

func (*GroupID) ProtoMessage()

func (*GroupID) Reset added in v0.22.0 

func (m *GroupID) Reset()

func (*GroupID) Size added in v0.22.0 

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

func (*GroupID) String added in v0.22.0 

func (m *GroupID) String() string

func (*GroupID) Unmarshal added in v0.22.0 

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

func (*GroupID) XXX_DiscardUnknown added in v0.22.0 

func (m *GroupID) XXX_DiscardUnknown()

func (*GroupID) XXX_Marshal added in v0.22.0 

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

func (*GroupID) XXX_Merge added in v0.22.0 

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

func (*GroupID) XXX_Size added in v0.22.0 

func (m *GroupID) XXX_Size() int

func (*GroupID) XXX_Unmarshal added in v0.22.0 

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

type GroupIDs added in v0.30.0 

type GroupIDs 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 (*GroupIDs) Descriptor added in v0.30.0 

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

func (*GroupIDs) GetIds added in v0.30.0 

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

func (*GroupIDs) Marshal added in v0.30.0 

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

func (*GroupIDs) MarshalTo added in v0.30.0 

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

func (*GroupIDs) MarshalToSizedBuffer added in v0.30.0 

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

func (*GroupIDs) ProtoMessage added in v0.30.0 

func (*GroupIDs) ProtoMessage()

func (*GroupIDs) Reset added in v0.30.0 

func (m *GroupIDs) Reset()

func (*GroupIDs) Size added in v0.30.0 

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

func (*GroupIDs) String added in v0.30.0 

func (m *GroupIDs) String() string

func (*GroupIDs) Unmarshal added in v0.30.0 

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

func (*GroupIDs) XXX_DiscardUnknown added in v0.30.0 

func (m *GroupIDs) XXX_DiscardUnknown()

func (*GroupIDs) XXX_Marshal added in v0.30.0 

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

func (*GroupIDs) XXX_Merge added in v0.30.0 

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

func (*GroupIDs) XXX_Size added in v0.30.0 

func (m *GroupIDs) XXX_Size() int

func (*GroupIDs) XXX_Unmarshal added in v0.30.0 

func (m *GroupIDs) 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 {
	Publisher            string   `protobuf:"bytes,1,opt,name=publisher,proto3" json:"publisher,omitempty"`
	Subtopic             string   `protobuf:"bytes,2,opt,name=subtopic,proto3" json:"subtopic,omitempty"`
	Payload              []byte   `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	ContentType          string   `protobuf:"bytes,4,opt,name=contentType,proto3" json:"contentType,omitempty"`
	Protocol             string   `protobuf:"bytes,5,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Created              int64    `protobuf:"varint,6,opt,name=created,proto3" json:"created,omitempty"`
	Subject              string   `protobuf:"bytes,7,opt,name=subject,proto3" json:"subject,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetContentType added in v0.26.0 

func (m *Message) GetContentType() string

func (*Message) GetCreated 

func (m *Message) GetCreated() int64

func (*Message) GetPayload 

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

func (*Message) GetProtocol 

func (m *Message) GetProtocol() string

func (*Message) GetPublisher 

func (m *Message) GetPublisher() string

func (*Message) GetSubject added in v0.28.0 

func (m *Message) GetSubject() 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 OrgAccessReq added in v0.30.0 

type OrgAccessReq struct {
	OrgId                string   `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OrgAccessReq) Descriptor added in v0.30.0 

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

func (*OrgAccessReq) GetOrgId added in v0.30.0 

func (m *OrgAccessReq) GetOrgId() string

func (*OrgAccessReq) GetToken added in v0.30.0 

func (m *OrgAccessReq) GetToken() string

func (*OrgAccessReq) Marshal added in v0.30.0 

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

func (*OrgAccessReq) MarshalTo added in v0.30.0 

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

func (*OrgAccessReq) MarshalToSizedBuffer added in v0.30.0 

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

func (*OrgAccessReq) ProtoMessage added in v0.30.0 

func (*OrgAccessReq) ProtoMessage()

func (*OrgAccessReq) Reset added in v0.30.0 

func (m *OrgAccessReq) Reset()

func (*OrgAccessReq) Size added in v0.30.0 

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

func (*OrgAccessReq) String added in v0.30.0 

func (m *OrgAccessReq) String() string

func (*OrgAccessReq) Unmarshal added in v0.30.0 

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

func (*OrgAccessReq) XXX_DiscardUnknown added in v0.30.0 

func (m *OrgAccessReq) XXX_DiscardUnknown()

func (*OrgAccessReq) XXX_Marshal added in v0.30.0 

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

func (*OrgAccessReq) XXX_Merge added in v0.30.0 

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

func (*OrgAccessReq) XXX_Size added in v0.30.0 

func (m *OrgAccessReq) XXX_Size() int

func (*OrgAccessReq) XXX_Unmarshal added in v0.30.0 

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

type OrgID added in v0.25.0 

type OrgID 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 (*OrgID) Descriptor added in v0.25.0 

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

func (*OrgID) GetValue added in v0.25.0 

func (m *OrgID) GetValue() string

func (*OrgID) Marshal added in v0.25.0 

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

func (*OrgID) MarshalTo added in v0.25.0 

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

func (*OrgID) MarshalToSizedBuffer added in v0.25.0 

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

func (*OrgID) ProtoMessage added in v0.25.0 

func (*OrgID) ProtoMessage()

func (*OrgID) Reset added in v0.25.0 

func (m *OrgID) Reset()

func (*OrgID) Size added in v0.25.0 

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

func (*OrgID) String added in v0.25.0 

func (m *OrgID) String() string

func (*OrgID) Unmarshal added in v0.25.0 

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

func (*OrgID) XXX_DiscardUnknown added in v0.25.0 

func (m *OrgID) XXX_DiscardUnknown()

func (*OrgID) XXX_Marshal added in v0.25.0 

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

func (*OrgID) XXX_Merge added in v0.25.0 

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

func (*OrgID) XXX_Size added in v0.25.0 

func (m *OrgID) XXX_Size() int

func (*OrgID) XXX_Unmarshal added in v0.25.0 

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

type OwnerID added in v0.25.0 

type OwnerID 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 (*OwnerID) Descriptor added in v0.25.0 

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

func (*OwnerID) GetValue added in v0.25.0 

func (m *OwnerID) GetValue() string

func (*OwnerID) Marshal added in v0.25.0 

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

func (*OwnerID) MarshalTo added in v0.25.0 

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

func (*OwnerID) MarshalToSizedBuffer added in v0.25.0 

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

func (*OwnerID) ProtoMessage added in v0.25.0 

func (*OwnerID) ProtoMessage()

func (*OwnerID) Reset added in v0.25.0 

func (m *OwnerID) Reset()

func (*OwnerID) Size added in v0.25.0 

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

func (*OwnerID) String added in v0.25.0 

func (m *OwnerID) String() string

func (*OwnerID) Unmarshal added in v0.25.0 

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

func (*OwnerID) XXX_DiscardUnknown added in v0.25.0 

func (m *OwnerID) XXX_DiscardUnknown()

func (*OwnerID) XXX_Marshal added in v0.25.0 

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

func (*OwnerID) XXX_Merge added in v0.25.0 

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

func (*OwnerID) XXX_Size added in v0.25.0 

func (m *OwnerID) XXX_Size() int

func (*OwnerID) XXX_Unmarshal added in v0.25.0 

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

type PageMetadata added in v0.29.1 

type PageMetadata 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"`
	Email                string   `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"`
	Order                string   `protobuf:"bytes,5,opt,name=order,proto3" json:"order,omitempty"`
	Dir                  string   `protobuf:"bytes,6,opt,name=dir,proto3" json:"dir,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PageMetadata) Descriptor added in v0.29.1 

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

func (*PageMetadata) GetDir added in v0.29.1 

func (m *PageMetadata) GetDir() string

func (*PageMetadata) GetEmail added in v0.29.1 

func (m *PageMetadata) GetEmail() string

func (*PageMetadata) GetLimit added in v0.29.1 

func (m *PageMetadata) GetLimit() uint64

func (*PageMetadata) GetOffset added in v0.29.1 

func (m *PageMetadata) GetOffset() uint64

func (*PageMetadata) GetOrder added in v0.29.1 

func (m *PageMetadata) GetOrder() string

func (*PageMetadata) GetTotal added in v0.29.1 

func (m *PageMetadata) GetTotal() uint64

func (*PageMetadata) Marshal added in v0.29.1 

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

func (*PageMetadata) MarshalTo added in v0.29.1 

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

func (*PageMetadata) MarshalToSizedBuffer added in v0.29.1 

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

func (*PageMetadata) ProtoMessage added in v0.29.1 

func (*PageMetadata) ProtoMessage()

func (*PageMetadata) Reset added in v0.29.1 

func (m *PageMetadata) Reset()

func (*PageMetadata) Size added in v0.29.1 

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

func (*PageMetadata) String added in v0.29.1 

func (m *PageMetadata) String() string

func (*PageMetadata) Unmarshal added in v0.29.1 

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

func (*PageMetadata) XXX_DiscardUnknown added in v0.29.1 

func (m *PageMetadata) XXX_DiscardUnknown()

func (*PageMetadata) XXX_Marshal added in v0.29.1 

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

func (*PageMetadata) XXX_Merge added in v0.29.1 

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

func (*PageMetadata) XXX_Size added in v0.29.1 

func (m *PageMetadata) XXX_Size() int

func (*PageMetadata) XXX_Unmarshal added in v0.29.1 

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

type ProfileID added in v0.28.0 

type ProfileID 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 (*ProfileID) Descriptor added in v0.28.0 

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

func (*ProfileID) GetValue added in v0.28.0 

func (m *ProfileID) GetValue() string

func (*ProfileID) Marshal added in v0.28.0 

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

func (*ProfileID) MarshalTo added in v0.28.0 

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

func (*ProfileID) MarshalToSizedBuffer added in v0.28.0 

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

func (*ProfileID) ProtoMessage added in v0.28.0 

func (*ProfileID) ProtoMessage()

func (*ProfileID) Reset added in v0.28.0 

func (m *ProfileID) Reset()

func (*ProfileID) Size added in v0.28.0 

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

func (*ProfileID) String added in v0.28.0 

func (m *ProfileID) String() string

func (*ProfileID) Unmarshal added in v0.28.0 

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

func (*ProfileID) XXX_DiscardUnknown added in v0.28.0 

func (m *ProfileID) XXX_DiscardUnknown()

func (*ProfileID) XXX_Marshal added in v0.28.0 

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

func (*ProfileID) XXX_Merge added in v0.28.0 

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

func (*ProfileID) XXX_Size added in v0.28.0 

func (m *ProfileID) XXX_Size() int

func (*ProfileID) XXX_Unmarshal added in v0.28.0 

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

type PubConfByKeyRes added in v0.24.0 

type PubConfByKeyRes struct {
	PublisherID          string   `protobuf:"bytes,1,opt,name=publisherID,proto3" json:"publisherID,omitempty"`
	ProfileConfig        *Config  `protobuf:"bytes,2,opt,name=profileConfig,proto3" json:"profileConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PubConfByKeyRes) Descriptor added in v0.24.0 

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

func (*PubConfByKeyRes) GetProfileConfig added in v0.24.0 

func (m *PubConfByKeyRes) GetProfileConfig() *Config

func (*PubConfByKeyRes) GetPublisherID added in v0.24.0 

func (m *PubConfByKeyRes) GetPublisherID() string

func (*PubConfByKeyRes) Marshal added in v0.24.0 

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

func (*PubConfByKeyRes) MarshalTo added in v0.24.0 

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

func (*PubConfByKeyRes) MarshalToSizedBuffer added in v0.24.0 

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

func (*PubConfByKeyRes) ProtoMessage added in v0.24.0 

func (*PubConfByKeyRes) ProtoMessage()

func (*PubConfByKeyRes) Reset added in v0.24.0 

func (m *PubConfByKeyRes) Reset()

func (*PubConfByKeyRes) Size added in v0.24.0 

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

func (*PubConfByKeyRes) String added in v0.24.0 

func (m *PubConfByKeyRes) String() string

func (*PubConfByKeyRes) Unmarshal added in v0.24.0 

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

func (*PubConfByKeyRes) XXX_DiscardUnknown added in v0.24.0 

func (m *PubConfByKeyRes) XXX_DiscardUnknown()

func (*PubConfByKeyRes) XXX_Marshal added in v0.24.0 

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

func (*PubConfByKeyRes) XXX_Merge added in v0.24.0 

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

func (*PubConfByKeyRes) XXX_Size added in v0.24.0 

func (m *PubConfByKeyRes) XXX_Size() int

func (*PubConfByKeyRes) XXX_Unmarshal added in v0.24.0 

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

type PublishReq added in v0.28.0 

type PublishReq struct {
	Message              *Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublishReq) Descriptor added in v0.28.0 

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

func (*PublishReq) GetMessage added in v0.28.0 

func (m *PublishReq) GetMessage() *Message

func (*PublishReq) Marshal added in v0.28.0 

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

func (*PublishReq) MarshalTo added in v0.28.0 

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

func (*PublishReq) MarshalToSizedBuffer added in v0.28.0 

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

func (*PublishReq) ProtoMessage added in v0.28.0 

func (*PublishReq) ProtoMessage()

func (*PublishReq) Reset added in v0.28.0 

func (m *PublishReq) Reset()

func (*PublishReq) Size added in v0.28.0 

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

func (*PublishReq) String added in v0.28.0 

func (m *PublishReq) String() string

func (*PublishReq) Unmarshal added in v0.28.0 

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

func (*PublishReq) XXX_DiscardUnknown added in v0.28.0 

func (m *PublishReq) XXX_DiscardUnknown()

func (*PublishReq) XXX_Marshal added in v0.28.0 

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

func (*PublishReq) XXX_Merge added in v0.28.0 

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

func (*PublishReq) XXX_Size added in v0.28.0 

func (m *PublishReq) XXX_Size() int

func (*PublishReq) XXX_Unmarshal added in v0.28.0 

func (m *PublishReq) 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 RulesServiceClient added in v0.28.0 

type RulesServiceClient interface {
	Publish(ctx context.Context, in *PublishReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

RulesServiceClient is the client API for RulesService service.

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

func NewRulesServiceClient added in v0.28.0 

func NewRulesServiceClient(cc *grpc.ClientConn) RulesServiceClient

type RulesServiceServer added in v0.28.0 

type RulesServiceServer interface {
	Publish(context.Context, *PublishReq) (*emptypb.Empty, error)
}

RulesServiceServer is the server API for RulesService service.

type ThingAccessReq added in v0.25.0 

type ThingAccessReq struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThingAccessReq) Descriptor added in v0.25.0 

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

func (*ThingAccessReq) GetId added in v0.25.0 

func (m *ThingAccessReq) GetId() string

func (*ThingAccessReq) GetKey added in v0.25.0 

func (m *ThingAccessReq) GetKey() string

func (*ThingAccessReq) Marshal added in v0.25.0 

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

func (*ThingAccessReq) MarshalTo added in v0.25.0 

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

func (*ThingAccessReq) MarshalToSizedBuffer added in v0.25.0 

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

func (*ThingAccessReq) ProtoMessage added in v0.25.0 

func (*ThingAccessReq) ProtoMessage()

func (*ThingAccessReq) Reset added in v0.25.0 

func (m *ThingAccessReq) Reset()

func (*ThingAccessReq) Size added in v0.25.0 

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

func (*ThingAccessReq) String added in v0.25.0 

func (m *ThingAccessReq) String() string

func (*ThingAccessReq) Unmarshal added in v0.25.0 

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

func (*ThingAccessReq) XXX_DiscardUnknown added in v0.25.0 

func (m *ThingAccessReq) XXX_DiscardUnknown()

func (*ThingAccessReq) XXX_Marshal added in v0.25.0 

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

func (*ThingAccessReq) XXX_Merge added in v0.25.0 

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

func (*ThingAccessReq) XXX_Size added in v0.25.0 

func (m *ThingAccessReq) XXX_Size() int

func (*ThingAccessReq) XXX_Unmarshal added in v0.25.0 

func (m *ThingAccessReq) 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 ThingIDs added in v0.31.1 

type ThingIDs 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 (*ThingIDs) Descriptor added in v0.31.1 

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

func (*ThingIDs) GetIds added in v0.31.1 

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

func (*ThingIDs) Marshal added in v0.31.1 

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

func (*ThingIDs) MarshalTo added in v0.31.1 

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

func (*ThingIDs) MarshalToSizedBuffer added in v0.31.1 

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

func (*ThingIDs) ProtoMessage added in v0.31.1 

func (*ThingIDs) ProtoMessage()

func (*ThingIDs) Reset added in v0.31.1 

func (m *ThingIDs) Reset()

func (*ThingIDs) Size added in v0.31.1 

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

func (*ThingIDs) String added in v0.31.1 

func (m *ThingIDs) String() string

func (*ThingIDs) Unmarshal added in v0.31.1 

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

func (*ThingIDs) XXX_DiscardUnknown added in v0.31.1 

func (m *ThingIDs) XXX_DiscardUnknown()

func (*ThingIDs) XXX_Marshal added in v0.31.1 

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

func (*ThingIDs) XXX_Merge added in v0.31.1 

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

func (*ThingIDs) XXX_Size added in v0.31.1 

func (m *ThingIDs) XXX_Size() int

func (*ThingIDs) XXX_Unmarshal added in v0.31.1 

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

type ThingKey added in v0.30.1 

type ThingKey struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ThingKey) Descriptor added in v0.30.1 

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

func (*ThingKey) GetType added in v0.30.1 

func (m *ThingKey) GetType() string

func (*ThingKey) GetValue added in v0.30.1 

func (m *ThingKey) GetValue() string

func (*ThingKey) Marshal added in v0.30.1 

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

func (*ThingKey) MarshalTo added in v0.30.1 

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

func (*ThingKey) MarshalToSizedBuffer added in v0.30.1 

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

func (*ThingKey) ProtoMessage added in v0.30.1 

func (*ThingKey) ProtoMessage()

func (*ThingKey) Reset added in v0.30.1 

func (m *ThingKey) Reset()

func (*ThingKey) Size added in v0.30.1 

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

func (*ThingKey) String added in v0.30.1 

func (m *ThingKey) String() string

func (*ThingKey) Unmarshal added in v0.30.1 

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

func (*ThingKey) XXX_DiscardUnknown added in v0.30.1 

func (m *ThingKey) XXX_DiscardUnknown()

func (*ThingKey) XXX_Marshal added in v0.30.1 

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

func (*ThingKey) XXX_Merge added in v0.30.1 

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

func (*ThingKey) XXX_Size added in v0.30.1 

func (m *ThingKey) XXX_Size() int

func (*ThingKey) XXX_Unmarshal added in v0.30.1 

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

type ThingsServiceClient 

type ThingsServiceClient interface {
	GetPubConfByKey(ctx context.Context, in *ThingKey, opts ...grpc.CallOption) (*PubConfByKeyRes, error)
	GetConfigByThingID(ctx context.Context, in *ThingID, opts ...grpc.CallOption) (*ConfigByThingIDRes, error)
	CanUserAccessThing(ctx context.Context, in *UserAccessReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CanUserAccessProfile(ctx context.Context, in *UserAccessReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CanUserAccessGroup(ctx context.Context, in *UserAccessReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CanThingAccessGroup(ctx context.Context, in *ThingAccessReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Identify(ctx context.Context, in *ThingKey, opts ...grpc.CallOption) (*ThingID, error)
	GetGroupIDByThingID(ctx context.Context, in *ThingID, opts ...grpc.CallOption) (*GroupID, error)
	GetGroupIDByProfileID(ctx context.Context, in *ProfileID, opts ...grpc.CallOption) (*GroupID, error)
	GetGroupIDsByOrg(ctx context.Context, in *OrgAccessReq, opts ...grpc.CallOption) (*GroupIDs, error)
	GetThingIDsByProfile(ctx context.Context, in *ProfileID, opts ...grpc.CallOption) (*ThingIDs, 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 {
	GetPubConfByKey(context.Context, *ThingKey) (*PubConfByKeyRes, error)
	GetConfigByThingID(context.Context, *ThingID) (*ConfigByThingIDRes, error)
	CanUserAccessThing(context.Context, *UserAccessReq) (*emptypb.Empty, error)
	CanUserAccessProfile(context.Context, *UserAccessReq) (*emptypb.Empty, error)
	CanUserAccessGroup(context.Context, *UserAccessReq) (*emptypb.Empty, error)
	CanThingAccessGroup(context.Context, *ThingAccessReq) (*emptypb.Empty, error)
	Identify(context.Context, *ThingKey) (*ThingID, error)
	GetGroupIDByThingID(context.Context, *ThingID) (*GroupID, error)
	GetGroupIDByProfileID(context.Context, *ProfileID) (*GroupID, error)
	GetGroupIDsByOrg(context.Context, *OrgAccessReq) (*GroupIDs, error)
	GetThingIDsByProfile(context.Context, *ProfileID) (*ThingIDs, 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 {
	DataFilters          []string `protobuf:"bytes,1,rep,name=dataFilters,proto3" json:"dataFilters,omitempty"`
	DataField            string   `protobuf:"bytes,2,opt,name=dataField,proto3" json:"dataField,omitempty"`
	TimeField            string   `protobuf:"bytes,3,opt,name=timeField,proto3" json:"timeField,omitempty"`
	TimeFormat           string   `protobuf:"bytes,4,opt,name=timeFormat,proto3" json:"timeFormat,omitempty"`
	TimeLocation         string   `protobuf:"bytes,5,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) GetDataField added in v0.24.1 

func (m *Transformer) GetDataField() string

func (*Transformer) GetDataFilters added in v0.24.1 

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

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) 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) ActivateOrgInvite added in v0.31.1 

func (*UnimplementedAuthServiceServer) ActivateOrgInvite(ctx context.Context, req *ActivateOrgInviteReq) (*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) CreateDormantOrgInvite added in v0.31.1 

func (*UnimplementedAuthServiceServer) CreateDormantOrgInvite(ctx context.Context, req *CreateDormantOrgInviteReq) (*emptypb.Empty, error)

func (*UnimplementedAuthServiceServer) GetOwnerIDByOrgID added in v0.25.0 

func (*UnimplementedAuthServiceServer) GetOwnerIDByOrgID(ctx context.Context, req *OrgID) (*OwnerID, 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 UnimplementedRulesServiceServer added in v0.28.0 

type UnimplementedRulesServiceServer struct {
}

UnimplementedRulesServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRulesServiceServer) Publish added in v0.28.0 

func (*UnimplementedRulesServiceServer) Publish(ctx context.Context, req *PublishReq) (*emptypb.Empty, error)

type UnimplementedThingsServiceServer 

type UnimplementedThingsServiceServer struct {
}

UnimplementedThingsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedThingsServiceServer) CanThingAccessGroup added in v0.25.0 

func (*UnimplementedThingsServiceServer) CanThingAccessGroup(ctx context.Context, req *ThingAccessReq) (*emptypb.Empty, error)

func (*UnimplementedThingsServiceServer) CanUserAccessGroup added in v0.25.0 

func (*UnimplementedThingsServiceServer) CanUserAccessGroup(ctx context.Context, req *UserAccessReq) (*emptypb.Empty, error)

func (*UnimplementedThingsServiceServer) CanUserAccessProfile added in v0.25.0 

func (*UnimplementedThingsServiceServer) CanUserAccessProfile(ctx context.Context, req *UserAccessReq) (*emptypb.Empty, error)

func (*UnimplementedThingsServiceServer) CanUserAccessThing added in v0.25.0 

func (*UnimplementedThingsServiceServer) CanUserAccessThing(ctx context.Context, req *UserAccessReq) (*emptypb.Empty, error)

func (*UnimplementedThingsServiceServer) GetConfigByThingID added in v0.24.0 

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

func (*UnimplementedThingsServiceServer) GetGroupIDByProfileID added in v0.28.0 

func (*UnimplementedThingsServiceServer) GetGroupIDByProfileID(ctx context.Context, req *ProfileID) (*GroupID, error)

func (*UnimplementedThingsServiceServer) GetGroupIDByThingID added in v0.22.0 

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

func (*UnimplementedThingsServiceServer) GetGroupIDsByOrg added in v0.30.0 

func (*UnimplementedThingsServiceServer) GetGroupIDsByOrg(ctx context.Context, req *OrgAccessReq) (*GroupIDs, error)

func (*UnimplementedThingsServiceServer) GetPubConfByKey added in v0.24.0 

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

func (*UnimplementedThingsServiceServer) GetThingIDsByProfile added in v0.31.1 

func (*UnimplementedThingsServiceServer) GetThingIDsByProfile(ctx context.Context, req *ProfileID) (*ThingIDs, error)

func (*UnimplementedThingsServiceServer) Identify 

func (*UnimplementedThingsServiceServer) Identify(ctx context.Context, req *ThingKey) (*ThingID, 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 UserAccessReq added in v0.25.0 

type UserAccessReq struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,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 (*UserAccessReq) Descriptor added in v0.25.0 

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

func (*UserAccessReq) GetAction added in v0.25.0 

func (m *UserAccessReq) GetAction() string

func (*UserAccessReq) GetId added in v0.25.0 

func (m *UserAccessReq) GetId() string

func (*UserAccessReq) GetToken added in v0.25.0 

func (m *UserAccessReq) GetToken() string

func (*UserAccessReq) Marshal added in v0.25.0 

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

func (*UserAccessReq) MarshalTo added in v0.25.0 

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

func (*UserAccessReq) MarshalToSizedBuffer added in v0.25.0 

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

func (*UserAccessReq) ProtoMessage added in v0.25.0 

func (*UserAccessReq) ProtoMessage()

func (*UserAccessReq) Reset added in v0.25.0 

func (m *UserAccessReq) Reset()

func (*UserAccessReq) Size added in v0.25.0 

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

func (*UserAccessReq) String added in v0.25.0 

func (m *UserAccessReq) String() string

func (*UserAccessReq) Unmarshal added in v0.25.0 

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

func (*UserAccessReq) XXX_DiscardUnknown added in v0.25.0 

func (m *UserAccessReq) XXX_DiscardUnknown()

func (*UserAccessReq) XXX_Marshal added in v0.25.0 

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

func (*UserAccessReq) XXX_Merge added in v0.25.0 

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

func (*UserAccessReq) XXX_Size added in v0.25.0 

func (m *UserAccessReq) XXX_Size() int

func (*UserAccessReq) XXX_Unmarshal added in v0.25.0 

func (m *UserAccessReq) 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"`
	PageMetadata         *PageMetadata `protobuf:"bytes,2,opt,name=pageMetadata,proto3" json:"pageMetadata,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) GetPageMetadata added in v0.29.1 

func (m *UsersByIDsReq) GetPageMetadata() *PageMetadata

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"`
	PageMetadata         *PageMetadata `protobuf:"bytes,2,opt,name=pageMetadata,proto3" json:"pageMetadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UsersRes) Descriptor 

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

func (*UsersRes) GetPageMetadata added in v0.29.1 

func (m *UsersRes) GetPageMetadata() *PageMetadata

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.