mgmt

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

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

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

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

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

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

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
}

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

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

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

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

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

type State struct {
	BloomHandler *processing.BloomHandler
}

type UnimplementedMgmtServiceServer struct {
}