knotpb

package module
v0.0.0-...-656f2ee Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMosquitoAuthServer 

func RegisterMosquitoAuthServer(s *grpc.Server, srv MosquitoAuthServer)

Types

type AllowPubkey 

type AllowPubkey struct {
	Pubkey               string   `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	Allow                bool     `protobuf:"varint,2,opt,name=allow,proto3" json:"allow,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AllowPubkey) Descriptor 

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

func (*AllowPubkey) GetAllow 

func (m *AllowPubkey) GetAllow() bool

func (*AllowPubkey) GetPubkey 

func (m *AllowPubkey) GetPubkey() string

func (*AllowPubkey) ProtoMessage 

func (*AllowPubkey) ProtoMessage()

func (*AllowPubkey) Reset 

func (m *AllowPubkey) Reset()

func (*AllowPubkey) String 

func (m *AllowPubkey) String() string

func (*AllowPubkey) XXX_DiscardUnknown 

func (m *AllowPubkey) XXX_DiscardUnknown()

func (*AllowPubkey) XXX_Marshal 

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

func (*AllowPubkey) XXX_Merge 

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

func (*AllowPubkey) XXX_Size 

func (m *AllowPubkey) XXX_Size() int

func (*AllowPubkey) XXX_Unmarshal 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type Knot 

type Knot struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Port                 string   `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	Wings                []string `protobuf:"bytes,4,rep,name=wings,proto3" json:"wings,omitempty"`
	Boottimestamp        int64    `protobuf:"varint,5,opt,name=boottimestamp,proto3" json:"boottimestamp,omitempty"`
	Mosquitoes           int32    `protobuf:"varint,6,opt,name=mosquitoes,proto3" json:"mosquitoes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Knot) Descriptor 

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

func (*Knot) GetBoottimestamp 

func (m *Knot) GetBoottimestamp() int64

func (*Knot) GetIp 

func (m *Knot) GetIp() string

func (*Knot) GetMosquitoes 

func (m *Knot) GetMosquitoes() int32

func (*Knot) GetName 

func (m *Knot) GetName() string

func (*Knot) GetPort 

func (m *Knot) GetPort() string

func (*Knot) GetWings 

func (m *Knot) GetWings() []string

func (*Knot) ProtoMessage 

func (*Knot) ProtoMessage()

func (*Knot) Reset 

func (m *Knot) Reset()

func (*Knot) String 

func (m *Knot) String() string

func (*Knot) XXX_DiscardUnknown 

func (m *Knot) XXX_DiscardUnknown()

func (*Knot) XXX_Marshal 

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

func (*Knot) XXX_Merge 

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

func (*Knot) XXX_Size 

func (m *Knot) XXX_Size() int

func (*Knot) XXX_Unmarshal 

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

type MosquitoAuthClient 

type MosquitoAuthClient interface {
	Authenticate(ctx context.Context, in *Pubkey, opts ...grpc.CallOption) (*MosquitoConfig, error)
	KnotList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (MosquitoAuth_KnotListClient, error)
}

MosquitoAuthClient is the client API for MosquitoAuth service.

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

func NewMosquitoAuthClient 

func NewMosquitoAuthClient(cc *grpc.ClientConn) MosquitoAuthClient

type MosquitoAuthServer 

type MosquitoAuthServer interface {
	Authenticate(context.Context, *Pubkey) (*MosquitoConfig, error)
	KnotList(*Empty, MosquitoAuth_KnotListServer) error
}

MosquitoAuthServer is the server API for MosquitoAuth service.

type MosquitoAuth_KnotListClient 

type MosquitoAuth_KnotListClient interface {
	Recv() (*Knot, error)
	grpc.ClientStream
}

type MosquitoAuth_KnotListServer 

type MosquitoAuth_KnotListServer interface {
	Send(*Knot) error
	grpc.ServerStream
}

type MosquitoConfig 

type MosquitoConfig struct {
	KnotPort             string   `protobuf:"bytes,1,opt,name=knotPort,proto3" json:"knotPort,omitempty"`
	KnotKey              string   `protobuf:"bytes,2,opt,name=knotKey,proto3" json:"knotKey,omitempty"`
	MosquitoKey          string   `protobuf:"bytes,3,opt,name=mosquitoKey,proto3" json:"mosquitoKey,omitempty"`
	MosquitoIP           string   `protobuf:"bytes,4,opt,name=mosquitoIP,proto3" json:"mosquitoIP,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MosquitoConfig) Descriptor 

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

func (*MosquitoConfig) GetKnotKey 

func (m *MosquitoConfig) GetKnotKey() string

func (*MosquitoConfig) GetKnotPort 

func (m *MosquitoConfig) GetKnotPort() string

func (*MosquitoConfig) GetMosquitoIP 

func (m *MosquitoConfig) GetMosquitoIP() string

func (*MosquitoConfig) GetMosquitoKey 

func (m *MosquitoConfig) GetMosquitoKey() string

func (*MosquitoConfig) ProtoMessage 

func (*MosquitoConfig) ProtoMessage()

func (*MosquitoConfig) Reset 

func (m *MosquitoConfig) Reset()

func (*MosquitoConfig) String 

func (m *MosquitoConfig) String() string

func (*MosquitoConfig) XXX_DiscardUnknown 

func (m *MosquitoConfig) XXX_DiscardUnknown()

func (*MosquitoConfig) XXX_Marshal 

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

func (*MosquitoConfig) XXX_Merge 

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

func (*MosquitoConfig) XXX_Size 

func (m *MosquitoConfig) XXX_Size() int

func (*MosquitoConfig) XXX_Unmarshal 

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

type Peer 

type Peer struct {
	Pubkey               string   `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor 

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

func (*Peer) GetIp 

func (m *Peer) GetIp() string

func (*Peer) GetPubkey 

func (m *Peer) GetPubkey() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

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

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

type Pubkey 

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

func (*Pubkey) Descriptor 

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

func (*Pubkey) GetPubkey 

func (m *Pubkey) GetPubkey() string

func (*Pubkey) ProtoMessage 

func (*Pubkey) ProtoMessage()

func (*Pubkey) Reset 

func (m *Pubkey) Reset()

func (*Pubkey) String 

func (m *Pubkey) String() string

func (*Pubkey) XXX_DiscardUnknown 

func (m *Pubkey) XXX_DiscardUnknown()

func (*Pubkey) XXX_Marshal 

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

func (*Pubkey) XXX_Merge 

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

func (*Pubkey) XXX_Size 

func (m *Pubkey) XXX_Size() int

func (*Pubkey) XXX_Unmarshal 

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

type UnimplementedMosquitoAuthServer 

type UnimplementedMosquitoAuthServer struct {
}

UnimplementedMosquitoAuthServer can be embedded to have forward compatible implementations.

func (*UnimplementedMosquitoAuthServer) Authenticate 

func (*UnimplementedMosquitoAuthServer) Authenticate(ctx context.Context, req *Pubkey) (*MosquitoConfig, error)

func (*UnimplementedMosquitoAuthServer) KnotList 

func (*UnimplementedMosquitoAuthServer) KnotList(req *Empty, srv MosquitoAuth_KnotListServer) error

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.