api

package
v0.0.0-...-96862d9 Latest Latest
Warning

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

Go to latest
Published: May 16, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func NewServer

func NewServer(kv kv.KV, ps pubsub.PubSub, logger zerolog.Logger) *server

func RegisterGonfigServer

func RegisterGonfigServer(s *grpc.Server, srv GonfigServer)

Types

type GetConfigRequest

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

func (*GetConfigRequest) Descriptor deprecated

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

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) GetConfigPath

func (x *GetConfigRequest) GetConfigPath() string

func (*GetConfigRequest) ProtoMessage

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect

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

func (*GetConfigRequest) Reset

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String

func (x *GetConfigRequest) String() string

type GetConfigResponse

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

func (*GetConfigResponse) Descriptor deprecated

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

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetConfig

func (x *GetConfigResponse) GetConfig() string

func (*GetConfigResponse) ProtoMessage

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect

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

func (*GetConfigResponse) Reset

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String

func (x *GetConfigResponse) String() string

type GonfigClient

type GonfigClient interface {
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	WatchConfig(ctx context.Context, in *WatchConfigRequest, opts ...grpc.CallOption) (Gonfig_WatchConfigClient, error)
}

GonfigClient is the client API for Gonfig service.

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

func NewGonfigClient

func NewGonfigClient(cc grpc.ClientConnInterface) GonfigClient

type GonfigServer

type GonfigServer interface {
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	WatchConfig(*WatchConfigRequest, Gonfig_WatchConfigServer) error
}

GonfigServer is the server API for Gonfig service.

type Gonfig_WatchConfigClient

type Gonfig_WatchConfigClient interface {
	Recv() (*WatchConfigResponse, error)
	grpc.ClientStream
}

type Gonfig_WatchConfigServer

type Gonfig_WatchConfigServer interface {
	Send(*WatchConfigResponse) error
	grpc.ServerStream
}

type UnimplementedGonfigServer

type UnimplementedGonfigServer struct {
}

UnimplementedGonfigServer can be embedded to have forward compatible implementations.

func (*UnimplementedGonfigServer) GetConfig

func (*UnimplementedGonfigServer) WatchConfig

type WatchConfigRequest

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

func (*WatchConfigRequest) Descriptor deprecated

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

Deprecated: Use WatchConfigRequest.ProtoReflect.Descriptor instead.

func (*WatchConfigRequest) GetConfigPath

func (x *WatchConfigRequest) GetConfigPath() string

func (*WatchConfigRequest) ProtoMessage

func (*WatchConfigRequest) ProtoMessage()

func (*WatchConfigRequest) ProtoReflect

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

func (*WatchConfigRequest) Reset

func (x *WatchConfigRequest) Reset()

func (*WatchConfigRequest) String

func (x *WatchConfigRequest) String() string

type WatchConfigResponse

type WatchConfigResponse struct {
	SubscriptionID string `protobuf:"bytes,1,opt,name=subscriptionID,proto3" json:"subscriptionID,omitempty"`
	Event          string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchConfigResponse) Descriptor deprecated

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

Deprecated: Use WatchConfigResponse.ProtoReflect.Descriptor instead.

func (*WatchConfigResponse) GetEvent

func (x *WatchConfigResponse) GetEvent() string

func (*WatchConfigResponse) GetSubscriptionID

func (x *WatchConfigResponse) GetSubscriptionID() string

func (*WatchConfigResponse) ProtoMessage

func (*WatchConfigResponse) ProtoMessage()

func (*WatchConfigResponse) ProtoReflect

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

func (*WatchConfigResponse) Reset

func (x *WatchConfigResponse) Reset()

func (*WatchConfigResponse) String

func (x *WatchConfigResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL