sinks

package
v1.31.0 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_streammachine_api_sinks_v1_sinks_v1_proto protoreflect.FileDescriptor
View Source 
var SinksService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "streammachine.api.sinks.v1.SinksService",
	HandlerType: (*SinksServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListSinks",
			Handler:    _SinksService_ListSinks_Handler,
		},
		{
			MethodName: "GetSink",
			Handler:    _SinksService_GetSink_Handler,
		},
		{
			MethodName: "DeleteSink",
			Handler:    _SinksService_DeleteSink_Handler,
		},
		{
			MethodName: "CreateSink",
			Handler:    _SinksService_CreateSink_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "streammachine/api/sinks/v1/sinks_v1.proto",
}

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

Functions

func RegisterSinksServiceServer 

func RegisterSinksServiceServer(s grpc.ServiceRegistrar, srv SinksServiceServer)

Types

type CreateSinkRequest 

type CreateSinkRequest struct {
	Sink *v1.Sink `protobuf:"bytes,1,opt,name=sink,proto3" json:"sink,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSinkRequest) Descriptor deprecated 

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

Deprecated: Use CreateSinkRequest.ProtoReflect.Descriptor instead.

func (*CreateSinkRequest) GetSink 

func (x *CreateSinkRequest) GetSink() *v1.Sink

func (*CreateSinkRequest) ProtoMessage 

func (*CreateSinkRequest) ProtoMessage()

func (*CreateSinkRequest) ProtoReflect 

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

func (*CreateSinkRequest) Reset 

func (x *CreateSinkRequest) Reset()

func (*CreateSinkRequest) String 

func (x *CreateSinkRequest) String() string

type CreateSinkResponse 

type CreateSinkResponse struct {
	Sink *v1.Sink `protobuf:"bytes,1,opt,name=sink,proto3" json:"sink,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSinkResponse) Descriptor deprecated 

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

Deprecated: Use CreateSinkResponse.ProtoReflect.Descriptor instead.

func (*CreateSinkResponse) GetSink 

func (x *CreateSinkResponse) GetSink() *v1.Sink

func (*CreateSinkResponse) ProtoMessage 

func (*CreateSinkResponse) ProtoMessage()

func (*CreateSinkResponse) ProtoReflect 

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

func (*CreateSinkResponse) Reset 

func (x *CreateSinkResponse) Reset()

func (*CreateSinkResponse) String 

func (x *CreateSinkResponse) String() string

type DeleteSinkRequest 

type DeleteSinkRequest struct {
	Ref *v1.SinkRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// (-- api-linter: core::0135::request-unknown-fields=disabled
	//     aip.dev/not-precedent: We really need this field. --)
	Recursive bool `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSinkRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSinkRequest.ProtoReflect.Descriptor instead.

func (*DeleteSinkRequest) GetRecursive 

func (x *DeleteSinkRequest) GetRecursive() bool

func (*DeleteSinkRequest) GetRef 

func (x *DeleteSinkRequest) GetRef() *v1.SinkRef

func (*DeleteSinkRequest) ProtoMessage 

func (*DeleteSinkRequest) ProtoMessage()

func (*DeleteSinkRequest) ProtoReflect 

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

func (*DeleteSinkRequest) Reset 

func (x *DeleteSinkRequest) Reset()

func (*DeleteSinkRequest) String 

func (x *DeleteSinkRequest) String() string

type DeleteSinkResponse 

type DeleteSinkResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteSinkResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSinkResponse.ProtoReflect.Descriptor instead.

func (*DeleteSinkResponse) ProtoMessage 

func (*DeleteSinkResponse) ProtoMessage()

func (*DeleteSinkResponse) ProtoReflect 

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

func (*DeleteSinkResponse) Reset 

func (x *DeleteSinkResponse) Reset()

func (*DeleteSinkResponse) String 

func (x *DeleteSinkResponse) String() string

type GetSinkRequest 

type GetSinkRequest struct {
	Ref       *v1.SinkRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	Recursive bool        `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSinkRequest) Descriptor deprecated 

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

Deprecated: Use GetSinkRequest.ProtoReflect.Descriptor instead.

func (*GetSinkRequest) GetRecursive 

func (x *GetSinkRequest) GetRecursive() bool

func (*GetSinkRequest) GetRef 

func (x *GetSinkRequest) GetRef() *v1.SinkRef

func (*GetSinkRequest) ProtoMessage 

func (*GetSinkRequest) ProtoMessage()

func (*GetSinkRequest) ProtoReflect 

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

func (*GetSinkRequest) Reset 

func (x *GetSinkRequest) Reset()

func (*GetSinkRequest) String 

func (x *GetSinkRequest) String() string

type GetSinkResponse 

type GetSinkResponse struct {
	SinkTree *v1.SinkTree `protobuf:"bytes,1,opt,name=sink_tree,json=sinkTree,proto3" json:"sink_tree,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSinkResponse) Descriptor deprecated 

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

Deprecated: Use GetSinkResponse.ProtoReflect.Descriptor instead.

func (*GetSinkResponse) GetSinkTree 

func (x *GetSinkResponse) GetSinkTree() *v1.SinkTree

func (*GetSinkResponse) ProtoMessage 

func (*GetSinkResponse) ProtoMessage()

func (*GetSinkResponse) ProtoReflect 

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

func (*GetSinkResponse) Reset 

func (x *GetSinkResponse) Reset()

func (*GetSinkResponse) String 

func (x *GetSinkResponse) String() string

type ListSinksRequest 

type ListSinksRequest struct {
	BillingId string `protobuf:"bytes,1,opt,name=billing_id,json=billingId,proto3" json:"billing_id,omitempty"`
	Recursive bool   `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinksRequest) Descriptor deprecated 

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

Deprecated: Use ListSinksRequest.ProtoReflect.Descriptor instead.

func (*ListSinksRequest) GetBillingId 

func (x *ListSinksRequest) GetBillingId() string

func (*ListSinksRequest) GetRecursive 

func (x *ListSinksRequest) GetRecursive() bool

func (*ListSinksRequest) ProtoMessage 

func (*ListSinksRequest) ProtoMessage()

func (*ListSinksRequest) ProtoReflect 

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

func (*ListSinksRequest) Reset 

func (x *ListSinksRequest) Reset()

func (*ListSinksRequest) String 

func (x *ListSinksRequest) String() string

type ListSinksResponse 

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

func (*ListSinksResponse) Descriptor deprecated 

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

Deprecated: Use ListSinksResponse.ProtoReflect.Descriptor instead.

func (*ListSinksResponse) GetSinks 

func (x *ListSinksResponse) GetSinks() []*v1.SinkTree

func (*ListSinksResponse) ProtoMessage 

func (*ListSinksResponse) ProtoMessage()

func (*ListSinksResponse) ProtoReflect 

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

func (*ListSinksResponse) Reset 

func (x *ListSinksResponse) Reset()

func (*ListSinksResponse) String 

func (x *ListSinksResponse) String() string

type SinksServiceClient 

type SinksServiceClient interface {
	ListSinks(ctx context.Context, in *ListSinksRequest, opts ...grpc.CallOption) (*ListSinksResponse, error)
	GetSink(ctx context.Context, in *GetSinkRequest, opts ...grpc.CallOption) (*GetSinkResponse, error)
	DeleteSink(ctx context.Context, in *DeleteSinkRequest, opts ...grpc.CallOption) (*DeleteSinkResponse, error)
	CreateSink(ctx context.Context, in *CreateSinkRequest, opts ...grpc.CallOption) (*CreateSinkResponse, error)
}

SinksServiceClient is the client API for SinksService 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 NewSinksServiceClient 

func NewSinksServiceClient(cc grpc.ClientConnInterface) SinksServiceClient

type SinksServiceServer 

type SinksServiceServer interface {
	ListSinks(context.Context, *ListSinksRequest) (*ListSinksResponse, error)
	GetSink(context.Context, *GetSinkRequest) (*GetSinkResponse, error)
	DeleteSink(context.Context, *DeleteSinkRequest) (*DeleteSinkResponse, error)
	CreateSink(context.Context, *CreateSinkRequest) (*CreateSinkResponse, error)
	// contains filtered or unexported methods
}

SinksServiceServer is the server API for SinksService service. All implementations must embed UnimplementedSinksServiceServer for forward compatibility

type UnimplementedSinksServiceServer 

type UnimplementedSinksServiceServer struct {
}

UnimplementedSinksServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSinksServiceServer) CreateSink 

func (UnimplementedSinksServiceServer) CreateSink(context.Context, *CreateSinkRequest) (*CreateSinkResponse, error)

func (UnimplementedSinksServiceServer) DeleteSink 

func (UnimplementedSinksServiceServer) DeleteSink(context.Context, *DeleteSinkRequest) (*DeleteSinkResponse, error)

func (UnimplementedSinksServiceServer) GetSink 

func (UnimplementedSinksServiceServer) GetSink(context.Context, *GetSinkRequest) (*GetSinkResponse, error)

func (UnimplementedSinksServiceServer) ListSinks 

func (UnimplementedSinksServiceServer) ListSinks(context.Context, *ListSinksRequest) (*ListSinksResponse, error)

type UnsafeSinksServiceServer 

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

UnsafeSinksServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SinksServiceServer 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.