mainflux

package module
v0.0.0-...-81dd437 Latest Latest
Warning

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

 Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

README ¶

Mainflux

go report card license

banner

Mainflux is modern, scalable, secure, open-source, and patent-free IoT cloud platform written in Go.

It accepts user and thing (sensor, actuator, application) connections over various network protocols (i.e. HTTP, MQTT, WebSocket, CoAP), thus making a seamless bridge between them. It is used as the IoT middleware for building complex IoT solutions.

For more details, check out the official documentation.

Features

  • Multi-protocol connectivity and bridging (HTTP, MQTT, WebSocket and CoAP)
  • Device management and provisioning (Zero Touch provisioning)
  • Mutual TLS Authentication (mTLS) using X.509 Certificates
  • Fine-grained access control (policies, ABAC/RBAC)
  • Message persistence (Cassandra, InfluxDB, MongoDB and PostgresSQL)
  • Platform logging and instrumentation support (Grafana, Prometheus and OpenTracing)
  • Event sourcing
  • Container-based deployment using Docker and Kubernetes
  • LoRaWAN network integration
  • Edge Agent and Export services for remote IoT gateway management and edge computing
  • SDK
  • CLI
  • Small memory footprint and fast execution
  • Domain-driven design architecture, high-quality code and test coverage

Prerequisites

The following are needed to run Mainflux:

Developing Mainflux will also require:

Install

Once the prerequisites are installed, execute the following commands from the project's root:

docker-compose -f docker/docker-compose.yml up

This will bring up the Mainflux docker services and interconnect them. This command can also be executed using the project's included Makefile:

make run

If you want to run services from specific release checkout code from github and make sure that MF_RELEASE_TAG in .env is being set to match the release version

git checkout tags/<release_number> -b <release_number>
# e.g. `git checkout tags/0.13.0 -b 0.13.0`

Check that .env file contains:

MF_RELEASE_TAG=<release_number>

docker-compose should be used for development and testing deployments. For production we suggest using Kubernetes.

Usage

The quickest way to start using Mainflux is via the CLI. The latest version can be downloaded from the official releases page.

It can also be built and used from the project's root directory:

make cli
./build/mainfluxlabs-cli version

Additional details on using the CLI can be found in the CLI documentation.

Documentation

Official documentation is hosted at Mainflux official docs page. Documentation is auto-generated, checkout the instructions on official docs repository:

If you spot an error or a need for corrections, please let us know - or even better: send us a PR.

Authors

Main architect and BDFL of Mainflux project is @drasko.

Additionally, @nmarcetic and @janko-isidorovic assured overall architecture and design, while @manuio and @darkodraskovic helped with crafting initial implementation and continuously worked on the project evolutions.

Besides them, Mainflux is constantly improved and actively developed by @anovakovic01, @dusanb94, @srados, @gsaleh, @blokovi, @chombium, @mteodor and a large set of contributors.

Maintainers are listed in MAINTAINERS file.

The Mainflux team would like to give special thanks to @mijicd for his monumental work on designing and implementing a highly improved and optimized version of the platform, and @malidukica for his effort on implementing the initial user interface.

Professional Support

There are many companies offering professional support for the Mainflux system.

If you need this kind of support, best is to reach out to @drasko directly, and he will point you out to the best-matching support team.

Contributing

Thank you for your interest in Mainflux and the desire to contribute!

  1. Take a look at our open issues. The good-first-issue label is specifically for issues that are great for getting started.
  2. Checkout the contribution guide to learn more about our style and conventions.
  3. Make your changes compatible to our workflow.

License

Apache-2.0

Documentation ¶

Overview ¶

Package mainflux acts as an umbrella package containing multiple different microservices and defines all shared domain concepts.

Index ¶

Constants ¶

This section is empty.

Variables ¶

View Source 
var (
	ErrInvalidLengthAuth        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuth          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuth = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// Version represents the last service git tag in git history.
	// It's meant to be set using go build ldflags:
	// -ldflags "-X 'github.com/MainfluxLabs/mainflux.Version=0.0.0'"
	Version = "0.0.0"
	// Commit represents the service git commit hash.
	// It's meant to be set using go build ldflags:
	// -ldflags "-X 'github.com/MainfluxLabs/mainflux.Commit=ffffffff'"
	Commit = "ffffffff"
	// BuildTime represetns the service build time.
	// It's meant to be set using go build ldflags:
	// -ldflags "-X 'github.com/MainfluxLabs/mainflux.BuildTime=1970-01-01_00:00:00'"
	BuildTime = "1970-01-01_00:00:00"
)

Functions ¶

func Env ¶ 

func Env(key, fallback string) string

Env reads specified environment variable. If no value has been found, fallback is returned.

func Health ¶ 

func Health(service string) http.HandlerFunc

Health exposes an HTTP handler for retrieving service health.

func LoadEnvFile ¶ 

func LoadEnvFile(envfilepath string) error

LoadEnvFile loads environment variables defined in an .env formatted file.

func RegisterAuthServiceServer ¶ 

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

func RegisterThingsServiceServer ¶ 

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

func RegisterUsersServiceServer ¶ 

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

Types ¶

type AssignRoleReq ¶ 

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

func (*AssignRoleReq) Descriptor ¶ 

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

func (*AssignRoleReq) GetId ¶ 

func (m *AssignRoleReq) GetId() string

func (*AssignRoleReq) GetRole ¶ 

func (m *AssignRoleReq) GetRole() string

func (*AssignRoleReq) Marshal ¶ 

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

func (*AssignRoleReq) 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 Assignment ¶ 

type Assignment struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	GroupID              string   `protobuf:"bytes,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	MemberID             string   `protobuf:"bytes,3,opt,name=memberID,proto3" json:"memberID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Assignment) Descriptor ¶ 

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

func (*Assignment) GetGroupID ¶ 

func (m *Assignment) GetGroupID() string

func (*Assignment) GetMemberID ¶ 

func (m *Assignment) GetMemberID() string

func (*Assignment) GetToken ¶ 

func (m *Assignment) GetToken() string

func (*Assignment) Marshal ¶ 

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

func (*Assignment) MarshalTo ¶ 

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

func (*Assignment) MarshalToSizedBuffer ¶ 

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

func (*Assignment) ProtoMessage ¶ 

func (*Assignment) ProtoMessage()

func (*Assignment) Reset ¶ 

func (m *Assignment) Reset()

func (*Assignment) Size ¶ 

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

func (*Assignment) String ¶ 

func (m *Assignment) String() string

func (*Assignment) Unmarshal ¶ 

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

func (*Assignment) XXX_DiscardUnknown ¶ 

func (m *Assignment) XXX_DiscardUnknown()

func (*Assignment) XXX_Marshal ¶ 

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

func (*Assignment) XXX_Merge ¶ 

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

func (*Assignment) XXX_Size ¶ 

func (m *Assignment) XXX_Size() int

func (*Assignment) XXX_Unmarshal ¶ 

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

type AuthServiceClient ¶ 

type AuthServiceClient interface {
	Issue(ctx context.Context, in *IssueReq, opts ...grpc.CallOption) (*Token, error)
	Identify(ctx context.Context, in *Token, opts ...grpc.CallOption) (*UserIdentity, error)
	Authorize(ctx context.Context, in *AuthorizeReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AddPolicy(ctx context.Context, in *PolicyReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Assign(ctx context.Context, in *Assignment, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Members(ctx context.Context, in *MembersReq, opts ...grpc.CallOption) (*MembersRes, error)
	AssignRole(ctx context.Context, in *AssignRoleReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RetrieveRole(ctx context.Context, in *RetrieveRoleReq, opts ...grpc.CallOption) (*RetrieveRoleRes, error)
}

AuthServiceClient is the client API for AuthService service.

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

func NewAuthServiceClient ¶ 

func NewAuthServiceClient(cc *grpc.ClientConn) AuthServiceClient

type AuthServiceServer ¶ 

type AuthServiceServer interface {
	Issue(context.Context, *IssueReq) (*Token, error)
	Identify(context.Context, *Token) (*UserIdentity, error)
	Authorize(context.Context, *AuthorizeReq) (*emptypb.Empty, error)
	AddPolicy(context.Context, *PolicyReq) (*emptypb.Empty, error)
	Assign(context.Context, *Assignment) (*emptypb.Empty, error)
	Members(context.Context, *MembersReq) (*MembersRes, error)
	AssignRole(context.Context, *AssignRoleReq) (*emptypb.Empty, error)
	RetrieveRole(context.Context, *RetrieveRoleReq) (*RetrieveRoleRes, error)
}

AuthServiceServer is the server API for AuthService service.

type AuthorizeReq ¶ 

type AuthorizeReq struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Object               string   `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	Subject              string   `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	Action               string   `protobuf:"bytes,4,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AuthorizeReq) Descriptor ¶ 

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

func (*AuthorizeReq) GetAction ¶ 

func (m *AuthorizeReq) GetAction() string

func (*AuthorizeReq) GetObject ¶ 

func (m *AuthorizeReq) GetObject() string

func (*AuthorizeReq) GetSubject ¶ 

func (m *AuthorizeReq) GetSubject() string

func (*AuthorizeReq) GetToken ¶ 

func (m *AuthorizeReq) GetToken() string

func (*AuthorizeReq) Marshal ¶ 

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

func (*AuthorizeReq) 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 HealthInfo ¶ 

type HealthInfo struct {
	// Status contains service status.
	Status string `json:"status"`

	// Version contains current service version.
	Version string `json:"version"`

	// Commit represents the git hash commit.
	Commit string `json:"commit"`

	// Description contains service description.
	Description string `json:"description"`

	// BuildTime contains service build time.
	BuildTime string `json:"build_time"`
}

HealthInfo contains version endpoint response.

type IDProvider ¶ 

type IDProvider interface {
	// ID generates the unique identifier.
	ID() (string, error)
}

IDProvider specifies an API for generating unique identifiers.

type IssueReq ¶ 

type IssueReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Email                string   `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	Type                 uint32   `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IssueReq) Descriptor ¶ 

func (*IssueReq) 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 MembersReq ¶ 

type MembersReq struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	GroupID              string   `protobuf:"bytes,2,opt,name=groupID,proto3" json:"groupID,omitempty"`
	Offset               uint64   `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit                uint64   `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	Type                 string   `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MembersReq) Descriptor ¶ 

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

func (*MembersReq) GetGroupID ¶ 

func (m *MembersReq) GetGroupID() string

func (*MembersReq) GetLimit ¶ 

func (m *MembersReq) GetLimit() uint64

func (*MembersReq) GetOffset ¶ 

func (m *MembersReq) GetOffset() uint64

func (*MembersReq) GetToken ¶ 

func (m *MembersReq) GetToken() string

func (*MembersReq) GetType ¶ 

func (m *MembersReq) GetType() string

func (*MembersReq) Marshal ¶ 

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

func (*MembersReq) MarshalTo ¶ 

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

func (*MembersReq) MarshalToSizedBuffer ¶ 

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

func (*MembersReq) ProtoMessage ¶ 

func (*MembersReq) ProtoMessage()

func (*MembersReq) Reset ¶ 

func (m *MembersReq) Reset()

func (*MembersReq) Size ¶ 

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

func (*MembersReq) String ¶ 

func (m *MembersReq) String() string

func (*MembersReq) Unmarshal ¶ 

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

func (*MembersReq) XXX_DiscardUnknown ¶ 

func (m *MembersReq) XXX_DiscardUnknown()

func (*MembersReq) XXX_Marshal ¶ 

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

func (*MembersReq) XXX_Merge ¶ 

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

func (*MembersReq) XXX_Size ¶ 

func (m *MembersReq) XXX_Size() int

func (*MembersReq) XXX_Unmarshal ¶ 

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

type MembersRes ¶ 

type MembersRes struct {
	Total                uint64   `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Offset               uint64   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Members              []string `protobuf:"bytes,5,rep,name=members,proto3" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MembersRes) Descriptor ¶ 

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

func (*MembersRes) GetLimit ¶ 

func (m *MembersRes) GetLimit() uint64

func (*MembersRes) GetMembers ¶ 

func (m *MembersRes) GetMembers() []string

func (*MembersRes) GetOffset ¶ 

func (m *MembersRes) GetOffset() uint64

func (*MembersRes) GetTotal ¶ 

func (m *MembersRes) GetTotal() uint64

func (*MembersRes) GetType ¶ 

func (m *MembersRes) GetType() string

func (*MembersRes) Marshal ¶ 

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

func (*MembersRes) MarshalTo ¶ 

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

func (*MembersRes) MarshalToSizedBuffer ¶ 

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

func (*MembersRes) ProtoMessage ¶ 

func (*MembersRes) ProtoMessage()

func (*MembersRes) Reset ¶ 

func (m *MembersRes) Reset()

func (*MembersRes) Size ¶ 

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

func (*MembersRes) String ¶ 

func (m *MembersRes) String() string

func (*MembersRes) Unmarshal ¶ 

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

func (*MembersRes) XXX_DiscardUnknown ¶ 

func (m *MembersRes) XXX_DiscardUnknown()

func (*MembersRes) XXX_Marshal ¶ 

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

func (*MembersRes) XXX_Merge ¶ 

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

func (*MembersRes) XXX_Size ¶ 

func (m *MembersRes) XXX_Size() int

func (*MembersRes) XXX_Unmarshal ¶ 

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

type Notifier ¶ 

type Notifier struct {
	Protocol             string   `protobuf:"bytes,1,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Subtopics            []string `protobuf:"bytes,2,rep,name=subtopics,proto3" json:"subtopics,omitempty"`
	Contacts             []string `protobuf:"bytes,3,rep,name=contacts,proto3" json:"contacts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Notifier) Descriptor ¶ 

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

func (*Notifier) GetContacts ¶ 

func (m *Notifier) GetContacts() []string

func (*Notifier) GetProtocol ¶ 

func (m *Notifier) GetProtocol() string

func (*Notifier) GetSubtopics ¶ 

func (m *Notifier) GetSubtopics() []string

func (*Notifier) Marshal ¶ 

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

func (*Notifier) MarshalTo ¶ 

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

func (*Notifier) MarshalToSizedBuffer ¶ 

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

func (*Notifier) ProtoMessage ¶ 

func (*Notifier) ProtoMessage()

func (*Notifier) Reset ¶ 

func (m *Notifier) Reset()

func (*Notifier) Size ¶ 

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

func (*Notifier) String ¶ 

func (m *Notifier) String() string

func (*Notifier) Unmarshal ¶ 

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

func (*Notifier) XXX_DiscardUnknown ¶ 

func (m *Notifier) XXX_DiscardUnknown()

func (*Notifier) XXX_Marshal ¶ 

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

func (*Notifier) XXX_Merge ¶ 

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

func (*Notifier) XXX_Size ¶ 

func (m *Notifier) XXX_Size() int

func (*Notifier) XXX_Unmarshal ¶ 

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

type PolicyReq ¶ 

type PolicyReq struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Policy               string   `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	Subject              string   `protobuf:"bytes,3,opt,name=subject,proto3" json:"subject,omitempty"`
	Object               string   `protobuf:"bytes,4,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PolicyReq) Descriptor ¶ 

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

func (*PolicyReq) GetObject ¶ 

func (m *PolicyReq) GetObject() string

func (*PolicyReq) GetPolicy ¶ 

func (m *PolicyReq) GetPolicy() string

func (*PolicyReq) GetSubject ¶ 

func (m *PolicyReq) GetSubject() string

func (*PolicyReq) GetToken ¶ 

func (m *PolicyReq) GetToken() string

func (*PolicyReq) Marshal ¶ 

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

func (*PolicyReq) MarshalTo ¶ 

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

func (*PolicyReq) MarshalToSizedBuffer ¶ 

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

func (*PolicyReq) ProtoMessage ¶ 

func (*PolicyReq) ProtoMessage()

func (*PolicyReq) Reset ¶ 

func (m *PolicyReq) Reset()

func (*PolicyReq) Size ¶ 

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

func (*PolicyReq) String ¶ 

func (m *PolicyReq) String() string

func (*PolicyReq) Unmarshal ¶ 

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

func (*PolicyReq) XXX_DiscardUnknown ¶ 

func (m *PolicyReq) XXX_DiscardUnknown()

func (*PolicyReq) XXX_Marshal ¶ 

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

func (*PolicyReq) XXX_Merge ¶ 

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

func (*PolicyReq) XXX_Size ¶ 

func (m *PolicyReq) XXX_Size() int

func (*PolicyReq) XXX_Unmarshal ¶ 

func (m *PolicyReq) 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"`
	Notify               bool         `protobuf:"varint,3,opt,name=notify,proto3" json:"notify,omitempty"`
	Webhook              bool         `protobuf:"varint,4,opt,name=webhook,proto3" json:"webhook,omitempty"`
	Transformer          *Transformer `protobuf:"bytes,5,opt,name=transformer,proto3" json:"transformer,omitempty"`
	Notifier             *Notifier    `protobuf:"bytes,6,opt,name=notifier,proto3" json:"notifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Profile) Descriptor ¶ 

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

func (*Profile) GetContentType ¶ 

func (m *Profile) GetContentType() string

func (*Profile) GetNotifier ¶ 

func (m *Profile) GetNotifier() *Notifier

func (*Profile) GetNotify ¶ 

func (m *Profile) GetNotify() bool

func (*Profile) GetTransformer ¶ 

func (m *Profile) GetTransformer() *Transformer

func (*Profile) GetWebhook ¶ 

func (m *Profile) GetWebhook() bool

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 Response ¶ 

type Response interface {
	// Code returns HTTP response code.
	Code() int

	// Headers returns map of HTTP headers with their values.
	Headers() map[string]string

	// Empty indicates if HTTP response has content.
	Empty() bool
}

Response contains HTTP response specific methods.

type RetrieveRoleReq ¶ 

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

func (*RetrieveRoleReq) Descriptor ¶ 

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

func (*RetrieveRoleReq) GetId ¶ 

func (m *RetrieveRoleReq) GetId() string

func (*RetrieveRoleReq) Marshal ¶ 

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

func (*RetrieveRoleReq) 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 ThingOwnerReq ¶ 

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

func (*ThingOwnerReq) Descriptor ¶ 

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

func (*ThingOwnerReq) GetThingID ¶ 

func (m *ThingOwnerReq) GetThingID() string

func (*ThingOwnerReq) GetToken ¶ 

func (m *ThingOwnerReq) GetToken() string

func (*ThingOwnerReq) Marshal ¶ 

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

func (*ThingOwnerReq) MarshalTo ¶ 

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

func (*ThingOwnerReq) MarshalToSizedBuffer ¶ 

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

func (*ThingOwnerReq) ProtoMessage ¶ 

func (*ThingOwnerReq) ProtoMessage()

func (*ThingOwnerReq) Reset ¶ 

func (m *ThingOwnerReq) Reset()

func (*ThingOwnerReq) Size ¶ 

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

func (*ThingOwnerReq) String ¶ 

func (m *ThingOwnerReq) String() string

func (*ThingOwnerReq) Unmarshal ¶ 

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

func (*ThingOwnerReq) XXX_DiscardUnknown ¶ 

func (m *ThingOwnerReq) XXX_DiscardUnknown()

func (*ThingOwnerReq) XXX_Marshal ¶ 

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

func (*ThingOwnerReq) XXX_Merge ¶ 

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

func (*ThingOwnerReq) XXX_Size ¶ 

func (m *ThingOwnerReq) XXX_Size() int

func (*ThingOwnerReq) XXX_Unmarshal ¶ 

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

type ThingsServiceClient ¶ 

type ThingsServiceClient interface {
	GetConnByKey(ctx context.Context, in *ConnByKeyReq, opts ...grpc.CallOption) (*ConnByKeyRes, error)
	IsChannelOwner(ctx context.Context, in *ChannelOwnerReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	IsThingOwner(ctx context.Context, in *ThingOwnerReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Identify(ctx context.Context, in *Token, opts ...grpc.CallOption) (*ThingID, error)
	GetGroupsByIDs(ctx context.Context, in *GroupsReq, opts ...grpc.CallOption) (*GroupsRes, error)
}

ThingsServiceClient is the client API for ThingsService service.

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

func NewThingsServiceClient ¶ 

func NewThingsServiceClient(cc *grpc.ClientConn) ThingsServiceClient

type ThingsServiceServer ¶ 

type ThingsServiceServer interface {
	GetConnByKey(context.Context, *ConnByKeyReq) (*ConnByKeyRes, error)
	IsChannelOwner(context.Context, *ChannelOwnerReq) (*emptypb.Empty, error)
	IsThingOwner(context.Context, *ThingOwnerReq) (*emptypb.Empty, error)
	Identify(context.Context, *Token) (*ThingID, error)
	GetGroupsByIDs(context.Context, *GroupsReq) (*GroupsRes, error)
}

ThingsServiceServer is the server API for ThingsService service.

type Token ¶ 

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

If a token is not carrying any information itself, the type field can be used to determine how to validate the token. Also, different tokens can be encoded in different ways.

func (*Token) Descriptor ¶ 

func (*Token) 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) AddPolicy ¶ 

func (*UnimplementedAuthServiceServer) AddPolicy(ctx context.Context, req *PolicyReq) (*emptypb.Empty, error)

func (*UnimplementedAuthServiceServer) Assign ¶ 

func (*UnimplementedAuthServiceServer) Assign(ctx context.Context, req *Assignment) (*emptypb.Empty, error)

func (*UnimplementedAuthServiceServer) AssignRole ¶ 

func (*UnimplementedAuthServiceServer) AssignRole(ctx context.Context, req *AssignRoleReq) (*emptypb.Empty, error)

func (*UnimplementedAuthServiceServer) Authorize ¶ 

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

func (*UnimplementedAuthServiceServer) Identify ¶ 

func (*UnimplementedAuthServiceServer) Identify(ctx context.Context, req *Token) (*UserIdentity, error)

func (*UnimplementedAuthServiceServer) Issue ¶ 

func (*UnimplementedAuthServiceServer) Issue(ctx context.Context, req *IssueReq) (*Token, error)

func (*UnimplementedAuthServiceServer) Members ¶ 

func (*UnimplementedAuthServiceServer) Members(ctx context.Context, req *MembersReq) (*MembersRes, error)

func (*UnimplementedAuthServiceServer) RetrieveRole ¶ 

func (*UnimplementedAuthServiceServer) RetrieveRole(ctx context.Context, req *RetrieveRoleReq) (*RetrieveRoleRes, error)

type UnimplementedThingsServiceServer ¶ 

type UnimplementedThingsServiceServer struct {
}

UnimplementedThingsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedThingsServiceServer) GetConnByKey ¶ 

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

func (*UnimplementedThingsServiceServer) GetGroupsByIDs ¶ 

func (*UnimplementedThingsServiceServer) 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)

func (*UnimplementedThingsServiceServer) IsThingOwner ¶ 

func (*UnimplementedThingsServiceServer) IsThingOwner(ctx context.Context, req *ThingOwnerReq) (*emptypb.Empty, error)

type UnimplementedUsersServiceServer ¶ 

type UnimplementedUsersServiceServer struct {
}

UnimplementedUsersServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedUsersServiceServer) GetUsersByEmails ¶ 

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

func (*UnimplementedUsersServiceServer) GetUsersByIDs ¶ 

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

type User ¶ 

type User struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Email                string   `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	Status               string   `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*User) Descriptor ¶ 

func (*User) 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

Directories ¶

Path Synopsis
api
Package api contains implementation of Auth service HTTP API.
 Package api contains implementation of Auth service HTTP API.
api/grpc
Package grpc contains implementation of Auth service gRPC API.
 Package grpc contains implementation of Auth service gRPC API.
api/http
api/http/keys
api/http/orgs
jwt
mocks
postgres
Package postgres contains Key repository implementations using PostgreSQL as the underlying database.
 Package postgres contains Key repository implementations using PostgreSQL as the underlying database.
tracing
Package tracing contains middlewares that will add spans to existing traces.
 Package tracing contains middlewares that will add spans to existing traces.
Package bootstrap contains the domain concept definitions needed to support Mainflux bootstrap service functionality.
 Package bootstrap contains the domain concept definitions needed to support Mainflux bootstrap service functionality.
api
Package api contains implementation of bootstrap service HTTP API.
 Package api contains implementation of bootstrap service HTTP API.
mocks
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
 Package postgres contains repository implementations using PostgreSQL as the underlying database.
redis/consumer
Package consumer contains events consumer for events published by Things service.
 Package consumer contains events consumer for events published by Things service.
redis/producer
Package producer contains the domain events needed to support event sourcing of Bootstrap service actions.
 Package producer contains the domain events needed to support event sourcing of Bootstrap service actions.
Package certs contains the domain concept definitions needed to support Mainflux certs service functionality.
 Package certs contains the domain concept definitions needed to support Mainflux certs service functionality.
api
Package api contains implementation of certs service HTTP API.
 Package api contains implementation of certs service HTTP API.
mocks
pki
Package pki wraps vault client
 Package pki wraps vault client
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
 Package postgres contains repository implementations using PostgreSQL as the underlying database.
cmd
auth
bootstrap
certs
SPDX-License-Identifier: Apache-2.0
 SPDX-License-Identifier: Apache-2.0
cli
coap
http
influxdb-reader
influxdb-writer
lora
mongodb-reader
mongodb-writer
mqtt
postgres-reader
postgres-writer
provision
smpp-notifier
smtp-notifier
things
timescale-reader
timescale-writer
users
webhooks
ws
Package coap contains the domain concept definitions needed to support Mainflux CoAP adapter service functionality.
 Package coap contains the domain concept definitions needed to support Mainflux CoAP adapter service functionality.
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality.
 Package consumers contain the domain concept definitions needed to support Mainflux consumer services functionality.
notifiers
Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality.
 Package notifiers contain the domain concept definitions needed to support Mainflux notifications functionality.
notifiers/api
notifiers/mocks
notifiers/smpp
Package smpp contains the domain concept definitions needed to support Mainflux SMS notifications.
 Package smpp contains the domain concept definitions needed to support Mainflux SMS notifications.
notifiers/smtp
Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications.
 Package smtp contains the domain concept definitions needed to support Mainflux SMTP notifications.
writers
Package writers contain the domain concept definitions needed to support Mainflux writer services functionality.
 Package writers contain the domain concept definitions needed to support Mainflux writer services functionality.
writers/api
writers/influxdb
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality.
 Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB writer service functionality.
writers/mongodb
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality.
 Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB writer service functionality.
writers/postgres
Package postgres contains repository implementations using Postgres as the underlying database.
 Package postgres contains repository implementations using Postgres as the underlying database.
writers/timescale
Package timescale contains repository implementations using Timescale as the underlying database.
 Package timescale contains repository implementations using Timescale as the underlying database.
Package http contains the domain concept definitions needed to support Mainflux http adapter service functionality.
 Package http contains the domain concept definitions needed to support Mainflux http adapter service functionality.
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
internal
apiutil
dbutil
email
Package logger contains logger API definition, wrapper that can be used around any other logger.
 Package logger contains logger API definition, wrapper that can be used around any other logger.
api
mocks
mqtt
redis
api
api/http
Package http contains implementation of kit service HTTP API.
 Package http contains implementation of kit service HTTP API.
mocks
postgres
redis
Package redis contains cache implementations using Redis as the underlying database.
 Package redis contains cache implementations using Redis as the underlying database.
pkg
Package pkg contains library packages used by Mainflux services and external services that integrate with Mainflux.
 Package pkg contains library packages used by Mainflux services and external services that integrate with Mainflux.
auth
errors
messaging
messaging/brokers
messaging/mqtt
Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the Mainflux IoT platform.
 Package mqtt hold the implementation of the Publisher and PubSub interfaces for the MQTT messaging system, the internal messaging broker of the Mainflux IoT platform.
messaging/nats
Package nats hold the implementation of the Publisher and PubSub interfaces for the NATS messaging system, the internal messaging broker of the Mainflux IoT platform.
 Package nats hold the implementation of the Publisher and PubSub interfaces for the NATS messaging system, the internal messaging broker of the Mainflux IoT platform.
messaging/rabbitmq
Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the Mainflux IoT platform.
 Package rabbitmq holds the implementation of the Publisher and PubSub interfaces for the RabbitMQ messaging system, the internal messaging broker of the Mainflux IoT platform.
mocks
sdk/go
transformers
Package transformers contains the domain concept definitions needed to support Mainflux transformer services functionality.
 Package transformers contains the domain concept definitions needed to support Mainflux transformer services functionality.
transformers/json
transformers/senml
ulid
Package ulid provides a ULID identity provider.
 Package ulid provides a ULID identity provider.
uuid
Package uuid provides a UUID identity provider.
 Package uuid provides a UUID identity provider.
Package provision contains domain concept definitions needed to support Provision service feature, i.e.
 Package provision contains domain concept definitions needed to support Provision service feature, i.e.
api
api
influxdb
Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality.
 Package influxdb contains the domain concept definitions needed to support Mainflux InfluxDB reader service functionality.
mocks
mongodb
Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality.
 Package mongodb contains the domain concept definitions needed to support Mainflux MondoDB reader service functionality.
postgres
Package postgres contains repository implementations using Postgres as the underlying database.
 Package postgres contains repository implementations using Postgres as the underlying database.
timescale
Package timescale contains repository implementations using Timescale as the underlying database.
 Package timescale contains repository implementations using Timescale as the underlying database.
Package things contains the domain concept definitions needed to support Mainflux things service functionality.
 Package things contains the domain concept definitions needed to support Mainflux things service functionality.
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
api/grpc
Package grpc contains implementation of things service gRPC API.
 Package grpc contains implementation of things service gRPC API.
api/http
Package http contains implementation of things service HTTP API.
 Package http contains implementation of things service HTTP API.
mocks
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
 Package postgres contains repository implementations using PostgreSQL as the underlying database.
redis
Package redis contains cache implementations using Redis as the underlying database.
 Package redis contains cache implementations using Redis as the underlying database.
standalone
Package standalone contains implementation for auth service in single-user scenario.
 Package standalone contains implementation for auth service in single-user scenario.
tracing
Package tracing contains middlewares that will add spans to existing traces.
 Package tracing contains middlewares that will add spans to existing traces.
tools
mqtt-bench
mqtt-bench/cmd
provision
provision/cmd
api/grpc
Package grpc contains implementation of users service gRPC API.
 Package grpc contains implementation of users service gRPC API.
api/http
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
bcrypt
Package bcrypt provides a hasher implementation utilizing bcrypt.
 Package bcrypt provides a hasher implementation utilizing bcrypt.
emailer
mocks
postgres
Package postgres contains repository implementations using PostgreSQL as the underlying database.
 Package postgres contains repository implementations using PostgreSQL as the underlying database.
tracing
Package tracing contains middlewares that will add spans to existing traces.
 Package tracing contains middlewares that will add spans to existing traces.
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
api/http
Package http contains implementation of kit service HTTP API.
 Package http contains implementation of kit service HTTP API.
mocks
postgres
tracing
ws
api
Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
 Package api contains API-related concerns: endpoint definitions, middlewares and all resource representations.
mocks

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.