mgmt

package
v1.3.5 Latest Latest
Warning

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

 Go to latest Published: Mar 27, 2023 License: BSD-3-Clause Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_mgmt_proto protoreflect.FileDescriptor

Functions

func RegisterMgmtServiceServer 

func RegisterMgmtServiceServer(s *grpc.Server, srv MgmtServiceServer)

Types

type EndpointConfig 

type EndpointConfig struct {
	ListenerAddress string
	ServerAddress   string
	Network         string
	Params          map[string]interface{}
	TLSConfig       *tls.Config
	TLSDisable      bool
	Disable         bool
}

EndpointConfig ...

type GRPCEndpointConfig 

type GRPCEndpointConfig struct {
	EndpointConfig
	ServerOptions []grpc.ServerOption
	DialOptions   []grpc.DialOption
}

GRPCEndpointConfig ...

func EndpointConfigFromViper 

func EndpointConfigFromViper() GRPCEndpointConfig

EndpointConfigFromViper creates a new GRPCEndpointConfig from the relevant Viper configs

func (GRPCEndpointConfig) DialString 

func (e GRPCEndpointConfig) DialString() string

DialString returns a string from the given config that is suitable to be passed into a grpc.Dial() function.

type MgmtAliveRequest 

type MgmtAliveRequest struct {
	Alive string `protobuf:"bytes,1,opt,name=alive,proto3" json:"alive,omitempty"`
	// contains filtered or unexported fields
}

func (*MgmtAliveRequest) Descriptor deprecated 

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

Deprecated: Use MgmtAliveRequest.ProtoReflect.Descriptor instead.

func (*MgmtAliveRequest) GetAlive 

func (x *MgmtAliveRequest) GetAlive() string

func (*MgmtAliveRequest) ProtoMessage 

func (*MgmtAliveRequest) ProtoMessage()

func (*MgmtAliveRequest) ProtoReflect 

func (x *MgmtAliveRequest) ProtoReflect() protoreflect.Message

func (*MgmtAliveRequest) Reset 

func (x *MgmtAliveRequest) Reset()

func (*MgmtAliveRequest) String 

func (x *MgmtAliveRequest) String() string

type MgmtAliveResponse 

type MgmtAliveResponse struct {
	Echo string `protobuf:"bytes,1,opt,name=echo,proto3" json:"echo,omitempty"`
	// contains filtered or unexported fields
}

func (*MgmtAliveResponse) Descriptor deprecated 

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

Deprecated: Use MgmtAliveResponse.ProtoReflect.Descriptor instead.

func (*MgmtAliveResponse) GetEcho 

func (x *MgmtAliveResponse) GetEcho() string

func (*MgmtAliveResponse) ProtoMessage 

func (*MgmtAliveResponse) ProtoMessage()

func (*MgmtAliveResponse) ProtoReflect 

func (x *MgmtAliveResponse) ProtoReflect() protoreflect.Message

func (*MgmtAliveResponse) Reset 

func (x *MgmtAliveResponse) Reset()

func (*MgmtAliveResponse) String 

func (x *MgmtAliveResponse) String() string

type MgmtBloomAddRequest 

type MgmtBloomAddRequest struct {
	Ioc string `protobuf:"bytes,1,opt,name=ioc,proto3" json:"ioc,omitempty"`
	// contains filtered or unexported fields
}

func (*MgmtBloomAddRequest) Descriptor deprecated 

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

Deprecated: Use MgmtBloomAddRequest.ProtoReflect.Descriptor instead.

func (*MgmtBloomAddRequest) GetIoc 

func (x *MgmtBloomAddRequest) GetIoc() string

func (*MgmtBloomAddRequest) ProtoMessage 

func (*MgmtBloomAddRequest) ProtoMessage()

func (*MgmtBloomAddRequest) ProtoReflect 

func (x *MgmtBloomAddRequest) ProtoReflect() protoreflect.Message

func (*MgmtBloomAddRequest) Reset 

func (x *MgmtBloomAddRequest) Reset()

func (*MgmtBloomAddRequest) String 

func (x *MgmtBloomAddRequest) String() string

type MgmtBloomAddResponse 

type MgmtBloomAddResponse struct {
	Added uint64 `protobuf:"varint,1,opt,name=added,proto3" json:"added,omitempty"`
	// contains filtered or unexported fields
}

func (*MgmtBloomAddResponse) Descriptor deprecated 

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

Deprecated: Use MgmtBloomAddResponse.ProtoReflect.Descriptor instead.

func (*MgmtBloomAddResponse) GetAdded 

func (x *MgmtBloomAddResponse) GetAdded() uint64

func (*MgmtBloomAddResponse) ProtoMessage 

func (*MgmtBloomAddResponse) ProtoMessage()

func (*MgmtBloomAddResponse) ProtoReflect 

func (x *MgmtBloomAddResponse) ProtoReflect() protoreflect.Message

func (*MgmtBloomAddResponse) Reset 

func (x *MgmtBloomAddResponse) Reset()

func (*MgmtBloomAddResponse) String 

func (x *MgmtBloomAddResponse) String() string

type MgmtBloomInfoResponse 

type MgmtBloomInfoResponse struct {
	HasBloom  bool    `protobuf:"varint,1,opt,name=has_bloom,json=hasBloom,proto3" json:"has_bloom,omitempty"`
	Capacity  uint64  `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Elements  uint64  `protobuf:"varint,3,opt,name=elements,proto3" json:"elements,omitempty"`
	Bits      uint64  `protobuf:"varint,4,opt,name=bits,proto3" json:"bits,omitempty"`
	Hashfuncs uint64  `protobuf:"varint,5,opt,name=hashfuncs,proto3" json:"hashfuncs,omitempty"`
	Fpprob    float64 `protobuf:"fixed64,6,opt,name=fpprob,proto3" json:"fpprob,omitempty"`
	// contains filtered or unexported fields
}

func (*MgmtBloomInfoResponse) Descriptor deprecated 

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

Deprecated: Use MgmtBloomInfoResponse.ProtoReflect.Descriptor instead.

func (*MgmtBloomInfoResponse) GetBits 

func (x *MgmtBloomInfoResponse) GetBits() uint64

func (*MgmtBloomInfoResponse) GetCapacity 

func (x *MgmtBloomInfoResponse) GetCapacity() uint64

func (*MgmtBloomInfoResponse) GetElements 

func (x *MgmtBloomInfoResponse) GetElements() uint64

func (*MgmtBloomInfoResponse) GetFpprob 

func (x *MgmtBloomInfoResponse) GetFpprob() float64

func (*MgmtBloomInfoResponse) GetHasBloom 

func (x *MgmtBloomInfoResponse) GetHasBloom() bool

func (*MgmtBloomInfoResponse) GetHashfuncs 

func (x *MgmtBloomInfoResponse) GetHashfuncs() uint64

func (*MgmtBloomInfoResponse) ProtoMessage 

func (*MgmtBloomInfoResponse) ProtoMessage()

func (*MgmtBloomInfoResponse) ProtoReflect 

func (x *MgmtBloomInfoResponse) ProtoReflect() protoreflect.Message

func (*MgmtBloomInfoResponse) Reset 

func (x *MgmtBloomInfoResponse) Reset()

func (*MgmtBloomInfoResponse) String 

func (x *MgmtBloomInfoResponse) String() string

type MgmtServiceClient 

type MgmtServiceClient interface {
	Alive(ctx context.Context, in *MgmtAliveRequest, opts ...grpc.CallOption) (*MgmtAliveResponse, error)
	BloomInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MgmtBloomInfoResponse, error)
	BloomAdd(ctx context.Context, opts ...grpc.CallOption) (MgmtService_BloomAddClient, error)
	BloomSave(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	BloomReload(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

MgmtServiceClient is the client API for MgmtService service.

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

func NewMgmtServiceClient 

func NewMgmtServiceClient(cc grpc.ClientConnInterface) MgmtServiceClient

type MgmtServiceServer 

type MgmtServiceServer interface {
	Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error)
	BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error)
	BloomAdd(MgmtService_BloomAddServer) error
	BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
}

MgmtServiceServer is the server API for MgmtService service.

type MgmtService_BloomAddClient 

type MgmtService_BloomAddClient interface {
	Send(*MgmtBloomAddRequest) error
	CloseAndRecv() (*MgmtBloomAddResponse, error)
	grpc.ClientStream
}

type MgmtService_BloomAddServer 

type MgmtService_BloomAddServer interface {
	SendAndClose(*MgmtBloomAddResponse) error
	Recv() (*MgmtBloomAddRequest, error)
	grpc.ServerStream
}

type Server 

type Server interface {
	// ListenAndServe is expected to create a listener and to block until a
	// shutdown is invoked.
	ListenAndServe() error
	Stop()
}

Server ...

func NewMgmtServer 

func NewMgmtServer(parent context.Context, cfg GRPCEndpointConfig, state *State) (Server, error)

NewMgmtServer returns a new mamagement server instance registered with gRPC.

type State 

type State struct {
	BloomHandler *processing.BloomHandler
}

State contains references to components to be affected by RPC calls.

type UnimplementedMgmtServiceServer 

type UnimplementedMgmtServiceServer struct {
}

UnimplementedMgmtServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMgmtServiceServer) Alive 

func (*UnimplementedMgmtServiceServer) Alive(context.Context, *MgmtAliveRequest) (*MgmtAliveResponse, error)

func (*UnimplementedMgmtServiceServer) BloomAdd 

func (*UnimplementedMgmtServiceServer) BloomAdd(MgmtService_BloomAddServer) error

func (*UnimplementedMgmtServiceServer) BloomInfo 

func (*UnimplementedMgmtServiceServer) BloomInfo(context.Context, *emptypb.Empty) (*MgmtBloomInfoResponse, error)

func (*UnimplementedMgmtServiceServer) BloomReload 

func (*UnimplementedMgmtServiceServer) BloomReload(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*UnimplementedMgmtServiceServer) BloomSave 

func (*UnimplementedMgmtServiceServer) BloomSave(context.Context, *emptypb.Empty) (*emptypb.Empty, 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.