streams

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_streams_v1_streams_v1_proto protoreflect.FileDescriptor
View Source 
var StreamsService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "streammachine.api.streams.v1.StreamsService",
	HandlerType: (*StreamsServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListStreams",
			Handler:    _StreamsService_ListStreams_Handler,
		},
		{
			MethodName: "GetStream",
			Handler:    _StreamsService_GetStream_Handler,
		},
		{
			MethodName: "DeleteStream",
			Handler:    _StreamsService_DeleteStream_Handler,
		},
		{
			MethodName: "CreateStream",
			Handler:    _StreamsService_CreateStream_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "streammachine/api/streams/v1/streams_v1.proto",
}

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

Functions

func RegisterStreamsServiceServer 

func RegisterStreamsServiceServer(s grpc.ServiceRegistrar, srv StreamsServiceServer)

Types

type CreateStreamRequest 

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

func (*CreateStreamRequest) Descriptor deprecated 

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

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetStream 

func (x *CreateStreamRequest) GetStream() *v1.Stream

func (*CreateStreamRequest) ProtoMessage 

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect 

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

func (*CreateStreamRequest) Reset 

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String 

func (x *CreateStreamRequest) String() string

type CreateStreamResponse 

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

func (*CreateStreamResponse) Descriptor deprecated 

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

Deprecated: Use CreateStreamResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamResponse) GetStream 

func (x *CreateStreamResponse) GetStream() *v1.Stream

func (*CreateStreamResponse) ProtoMessage 

func (*CreateStreamResponse) ProtoMessage()

func (*CreateStreamResponse) ProtoReflect 

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

func (*CreateStreamResponse) Reset 

func (x *CreateStreamResponse) Reset()

func (*CreateStreamResponse) String 

func (x *CreateStreamResponse) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	Ref *v1.StreamRef `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 (*DeleteStreamRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStreamRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamRequest) GetRecursive 

func (x *DeleteStreamRequest) GetRecursive() bool

func (*DeleteStreamRequest) GetRef 

func (x *DeleteStreamRequest) GetRef() *v1.StreamRef

func (*DeleteStreamRequest) ProtoMessage 

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) ProtoReflect 

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

func (*DeleteStreamRequest) Reset 

func (x *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String 

func (x *DeleteStreamRequest) String() string

type DeleteStreamResponse 

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

func (*DeleteStreamResponse) Descriptor deprecated 

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

Deprecated: Use DeleteStreamResponse.ProtoReflect.Descriptor instead.

func (*DeleteStreamResponse) ProtoMessage 

func (*DeleteStreamResponse) ProtoMessage()

func (*DeleteStreamResponse) ProtoReflect 

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

func (*DeleteStreamResponse) Reset 

func (x *DeleteStreamResponse) Reset()

func (*DeleteStreamResponse) String 

func (x *DeleteStreamResponse) String() string

type GetStreamRequest 

type GetStreamRequest struct {
	Ref       *v1.StreamRef `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 (*GetStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamRequest.ProtoReflect.Descriptor instead.

func (*GetStreamRequest) GetRecursive 

func (x *GetStreamRequest) GetRecursive() bool

func (*GetStreamRequest) GetRef 

func (x *GetStreamRequest) GetRef() *v1.StreamRef

func (*GetStreamRequest) ProtoMessage 

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) ProtoReflect 

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

func (*GetStreamRequest) Reset 

func (x *GetStreamRequest) Reset()

func (*GetStreamRequest) String 

func (x *GetStreamRequest) String() string

type GetStreamResponse 

type GetStreamResponse struct {
	StreamTree *v1.StreamTree `protobuf:"bytes,1,opt,name=stream_tree,json=streamTree,proto3" json:"stream_tree,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamResponse.ProtoReflect.Descriptor instead.

func (*GetStreamResponse) GetStreamTree 

func (x *GetStreamResponse) GetStreamTree() *v1.StreamTree

func (*GetStreamResponse) ProtoMessage 

func (*GetStreamResponse) ProtoMessage()

func (*GetStreamResponse) ProtoReflect 

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

func (*GetStreamResponse) Reset 

func (x *GetStreamResponse) Reset()

func (*GetStreamResponse) String 

func (x *GetStreamResponse) String() string

type ListStreamsRequest 

type ListStreamsRequest 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 (*ListStreamsRequest) Descriptor deprecated 

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

Deprecated: Use ListStreamsRequest.ProtoReflect.Descriptor instead.

func (*ListStreamsRequest) GetBillingId 

func (x *ListStreamsRequest) GetBillingId() string

func (*ListStreamsRequest) GetRecursive 

func (x *ListStreamsRequest) GetRecursive() bool

func (*ListStreamsRequest) ProtoMessage 

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) ProtoReflect 

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

func (*ListStreamsRequest) Reset 

func (x *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String 

func (x *ListStreamsRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {
	Streams []*v1.StreamTree `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamsResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamsResponse.ProtoReflect.Descriptor instead.

func (*ListStreamsResponse) GetStreams 

func (x *ListStreamsResponse) GetStreams() []*v1.StreamTree

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) ProtoReflect 

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

func (*ListStreamsResponse) Reset 

func (x *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (x *ListStreamsResponse) String() string

type StreamsServiceClient 

type StreamsServiceClient interface {
	ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*GetStreamResponse, error)
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*DeleteStreamResponse, error)
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error)
}

StreamsServiceClient is the client API for StreamsService 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 NewStreamsServiceClient 

func NewStreamsServiceClient(cc grpc.ClientConnInterface) StreamsServiceClient

type StreamsServiceServer 

type StreamsServiceServer interface {
	ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
	GetStream(context.Context, *GetStreamRequest) (*GetStreamResponse, error)
	DeleteStream(context.Context, *DeleteStreamRequest) (*DeleteStreamResponse, error)
	CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)
	// contains filtered or unexported methods
}

StreamsServiceServer is the server API for StreamsService service. All implementations must embed UnimplementedStreamsServiceServer for forward compatibility

type UnimplementedStreamsServiceServer 

type UnimplementedStreamsServiceServer struct {
}

UnimplementedStreamsServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamsServiceServer) CreateStream 

func (UnimplementedStreamsServiceServer) CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)

func (UnimplementedStreamsServiceServer) DeleteStream 

func (UnimplementedStreamsServiceServer) DeleteStream(context.Context, *DeleteStreamRequest) (*DeleteStreamResponse, error)

func (UnimplementedStreamsServiceServer) GetStream 

func (UnimplementedStreamsServiceServer) GetStream(context.Context, *GetStreamRequest) (*GetStreamResponse, error)

func (UnimplementedStreamsServiceServer) ListStreams 

func (UnimplementedStreamsServiceServer) ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)

type UnsafeStreamsServiceServer 

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

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