protoconfservice

Documentation

Index

• Variables
• func RegisterProtoconfServiceServer(s grpc.ServiceRegistrar, srv ProtoconfServiceServer)
• type ConfigSubscriptionRequest
  • func (*ConfigSubscriptionRequest) Descriptor() ([]byte, []int)
  • func (x *ConfigSubscriptionRequest) GetChannel() string
  • func (x *ConfigSubscriptionRequest) GetPath() string
  • func (*ConfigSubscriptionRequest) ProtoMessage()
  • func (x *ConfigSubscriptionRequest) ProtoReflect() protoreflect.Message
  • func (x *ConfigSubscriptionRequest) Reset()
  • func (x *ConfigSubscriptionRequest) String() string
• type ConfigUpdate
  • func (*ConfigUpdate) Descriptor() ([]byte, []int)
  • func (x *ConfigUpdate) GetError() string
  • func (x *ConfigUpdate) GetValue() *anypb.Any
  • func (*ConfigUpdate) ProtoMessage()
  • func (x *ConfigUpdate) ProtoReflect() protoreflect.Message
  • func (x *ConfigUpdate) Reset()
  • func (x *ConfigUpdate) String() string
• type ProtoconfServiceClient
  • func NewProtoconfServiceClient(cc grpc.ClientConnInterface) ProtoconfServiceClient
• type ProtoconfServiceServer
• type ProtoconfService_SubscribeForConfigClient
• type ProtoconfService_SubscribeForConfigServer
• type UnimplementedProtoconfServiceServer
  • func (UnimplementedProtoconfServiceServer) SubscribeForConfig(*ConfigSubscriptionRequest, ProtoconfService_SubscribeForConfigServer) error
• type UnsafeProtoconfServiceServer

Variables

var File_agent_api_proto_v1_protoconf_service_proto protoreflect.FileDescriptor

var ProtoconfService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.ProtoconfService",
	HandlerType: (*ProtoconfServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SubscribeForConfig",
			Handler:       _ProtoconfService_SubscribeForConfig_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent/api/proto/v1/protoconf_service.proto",
}

ProtoconfService_ServiceDesc is the grpc.ServiceDesc for ProtoconfService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterProtoconfServiceServer

func RegisterProtoconfServiceServer(s grpc.ServiceRegistrar, srv ProtoconfServiceServer)

Types

type ConfigSubscriptionRequest

type ConfigSubscriptionRequest struct {
	Path    string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigSubscriptionRequest) Descriptor

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

Deprecated: Use ConfigSubscriptionRequest.ProtoReflect.Descriptor instead.

func (*ConfigSubscriptionRequest) GetChannel

func (x *ConfigSubscriptionRequest) GetChannel() string

func (*ConfigSubscriptionRequest) GetPath

func (x *ConfigSubscriptionRequest) GetPath() string

func (*ConfigSubscriptionRequest) ProtoMessage

func (*ConfigSubscriptionRequest) ProtoMessage()

func (*ConfigSubscriptionRequest) ProtoReflect

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

func (*ConfigSubscriptionRequest) Reset

func (x *ConfigSubscriptionRequest) Reset()

func (*ConfigSubscriptionRequest) String

func (x *ConfigSubscriptionRequest) String() string

type ConfigUpdate

type ConfigUpdate struct {
	Value *anypb.Any `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigUpdate) Descriptor

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

Deprecated: Use ConfigUpdate.ProtoReflect.Descriptor instead.

func (*ConfigUpdate) GetError

func (x *ConfigUpdate) GetError() string

func (*ConfigUpdate) GetValue

func (x *ConfigUpdate) GetValue() *anypb.Any

func (*ConfigUpdate) ProtoMessage

func (*ConfigUpdate) ProtoMessage()

func (*ConfigUpdate) ProtoReflect

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

func (*ConfigUpdate) Reset

func (x *ConfigUpdate) Reset()

func (*ConfigUpdate) String

func (x *ConfigUpdate) String() string

type ProtoconfServiceClient

type ProtoconfServiceClient interface {
	SubscribeForConfig(ctx context.Context, in *ConfigSubscriptionRequest, opts ...grpc.CallOption) (ProtoconfService_SubscribeForConfigClient, error)
}

ProtoconfServiceClient is the client API for ProtoconfService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProtoconfServiceClient

func NewProtoconfServiceClient(cc grpc.ClientConnInterface) ProtoconfServiceClient

type ProtoconfServiceServer

type ProtoconfServiceServer interface {
	SubscribeForConfig(*ConfigSubscriptionRequest, ProtoconfService_SubscribeForConfigServer) error
	// contains filtered or unexported methods
}

ProtoconfServiceServer is the server API for ProtoconfService service. All implementations must embed UnimplementedProtoconfServiceServer for forward compatibility

type ProtoconfService_SubscribeForConfigClient

type ProtoconfService_SubscribeForConfigClient interface {
	Recv() (*ConfigUpdate, error)
	grpc.ClientStream
}

type ProtoconfService_SubscribeForConfigServer

type ProtoconfService_SubscribeForConfigServer interface {
	Send(*ConfigUpdate) error
	grpc.ServerStream
}

type UnimplementedProtoconfServiceServer

type UnimplementedProtoconfServiceServer struct {
}

UnimplementedProtoconfServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProtoconfServiceServer) SubscribeForConfig

func (UnimplementedProtoconfServiceServer) SubscribeForConfig(*ConfigSubscriptionRequest, ProtoconfService_SubscribeForConfigServer) error

type UnsafeProtoconfServiceServer

type UnsafeProtoconfServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeProtoconfServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProtoconfServiceServer will result in compilation errors.