pb

package
v0.29.0 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_sinks_pb_sinks_proto protoreflect.FileDescriptor
View Source 
var SinkService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sinks.SinkService",
	HandlerType: (*SinkServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RetrieveSink",
			Handler:    _SinkService_RetrieveSink_Handler,
		},
		{
			MethodName: "RetrieveSinks",
			Handler:    _SinkService_RetrieveSinks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sinks/pb/sinks.proto",
}

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

Functions

func RegisterSinkServiceServer 

func RegisterSinkServiceServer(s grpc.ServiceRegistrar, srv SinkServiceServer)

Types

type SinkByIDReq 

type SinkByIDReq struct {
	SinkID  string `protobuf:"bytes,1,opt,name=sinkID,proto3" json:"sinkID,omitempty"`
	OwnerID string `protobuf:"bytes,2,opt,name=ownerID,proto3" json:"ownerID,omitempty"`
	// contains filtered or unexported fields
}

func (*SinkByIDReq) Descriptor deprecated 

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

Deprecated: Use SinkByIDReq.ProtoReflect.Descriptor instead.

func (*SinkByIDReq) GetOwnerID 

func (x *SinkByIDReq) GetOwnerID() string

func (*SinkByIDReq) GetSinkID 

func (x *SinkByIDReq) GetSinkID() string

func (*SinkByIDReq) ProtoMessage 

func (*SinkByIDReq) ProtoMessage()

func (*SinkByIDReq) ProtoReflect 

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

func (*SinkByIDReq) Reset 

func (x *SinkByIDReq) Reset()

func (*SinkByIDReq) String 

func (x *SinkByIDReq) String() string

type SinkRes 

type SinkRes struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Tags        []byte `protobuf:"bytes,4,opt,name=tags,proto3" json:"tags,omitempty"`
	State       string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	Error       string `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	Backend     string `protobuf:"bytes,7,opt,name=backend,proto3" json:"backend,omitempty"`
	Config      []byte `protobuf:"bytes,8,opt,name=config,proto3" json:"config,omitempty"`
	OwnerID     string `protobuf:"bytes,9,opt,name=ownerID,proto3" json:"ownerID,omitempty"`
	// contains filtered or unexported fields
}

func (*SinkRes) Descriptor deprecated 

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

Deprecated: Use SinkRes.ProtoReflect.Descriptor instead.

func (*SinkRes) GetBackend 

func (x *SinkRes) GetBackend() string

func (*SinkRes) GetConfig 

func (x *SinkRes) GetConfig() []byte

func (*SinkRes) GetDescription 

func (x *SinkRes) GetDescription() string

func (*SinkRes) GetError 

func (x *SinkRes) GetError() string

func (*SinkRes) GetId 

func (x *SinkRes) GetId() string

func (*SinkRes) GetName 

func (x *SinkRes) GetName() string

func (*SinkRes) GetOwnerID 

func (x *SinkRes) GetOwnerID() string

func (*SinkRes) GetState 

func (x *SinkRes) GetState() string

func (*SinkRes) GetTags 

func (x *SinkRes) GetTags() []byte

func (*SinkRes) ProtoMessage 

func (*SinkRes) ProtoMessage()

func (*SinkRes) ProtoReflect 

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

func (*SinkRes) Reset 

func (x *SinkRes) Reset()

func (*SinkRes) String 

func (x *SinkRes) String() string

type SinkServiceClient 

type SinkServiceClient interface {
	RetrieveSink(ctx context.Context, in *SinkByIDReq, opts ...grpc.CallOption) (*SinkRes, error)
	RetrieveSinks(ctx context.Context, in *SinksFilterReq, opts ...grpc.CallOption) (*SinksRes, error)
}

SinkServiceClient is the client API for SinkService 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 NewSinkServiceClient 

func NewSinkServiceClient(cc grpc.ClientConnInterface) SinkServiceClient

type SinkServiceServer 

type SinkServiceServer interface {
	RetrieveSink(context.Context, *SinkByIDReq) (*SinkRes, error)
	RetrieveSinks(context.Context, *SinksFilterReq) (*SinksRes, error)
	// contains filtered or unexported methods
}

SinkServiceServer is the server API for SinkService service. All implementations must embed UnimplementedSinkServiceServer for forward compatibility

type SinksFilterReq 

type SinksFilterReq struct {
	OtelEnabled string `protobuf:"bytes,1,opt,name=otelEnabled,proto3" json:"otelEnabled,omitempty"`
	State       string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*SinksFilterReq) Descriptor deprecated 

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

Deprecated: Use SinksFilterReq.ProtoReflect.Descriptor instead.

func (*SinksFilterReq) GetOtelEnabled 

func (x *SinksFilterReq) GetOtelEnabled() string

func (*SinksFilterReq) GetState 

func (x *SinksFilterReq) GetState() string

func (*SinksFilterReq) ProtoMessage 

func (*SinksFilterReq) ProtoMessage()

func (*SinksFilterReq) ProtoReflect 

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

func (*SinksFilterReq) Reset 

func (x *SinksFilterReq) Reset()

func (*SinksFilterReq) String 

func (x *SinksFilterReq) String() string

type SinksRes 

type SinksRes struct {
	Sinks []*SinkRes `protobuf:"bytes,1,rep,name=sinks,proto3" json:"sinks,omitempty"`
	// contains filtered or unexported fields
}

func (*SinksRes) Descriptor deprecated 

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

Deprecated: Use SinksRes.ProtoReflect.Descriptor instead.

func (*SinksRes) GetSinks 

func (x *SinksRes) GetSinks() []*SinkRes

func (*SinksRes) ProtoMessage 

func (*SinksRes) ProtoMessage()

func (*SinksRes) ProtoReflect 

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

func (*SinksRes) Reset 

func (x *SinksRes) Reset()

func (*SinksRes) String 

func (x *SinksRes) String() string

type UnimplementedSinkServiceServer 

type UnimplementedSinkServiceServer struct {
}

UnimplementedSinkServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSinkServiceServer) RetrieveSink 

func (UnimplementedSinkServiceServer) RetrieveSink(context.Context, *SinkByIDReq) (*SinkRes, error)

func (UnimplementedSinkServiceServer) RetrieveSinks 

func (UnimplementedSinkServiceServer) RetrieveSinks(context.Context, *SinksFilterReq) (*SinksRes, error)

type UnsafeSinkServiceServer 

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

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

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.