streamingv1

Documentation

Index

• Variables
• type CloseStreamRequest
  • func (x *CloseStreamRequest) GetStreamId() string
  • func (*CloseStreamRequest) ProtoMessage()
  • func (x *CloseStreamRequest) ProtoReflect() protoreflect.Message
  • func (x *CloseStreamRequest) Reset()
  • func (x *CloseStreamRequest) SetStreamId(v string)
  • func (x *CloseStreamRequest) String() string
• type CloseStreamRequest_builder
  • func (b0 CloseStreamRequest_builder) Build() *CloseStreamRequest
• type CloseStreamResponse
  • func (*CloseStreamResponse) ProtoMessage()
  • func (x *CloseStreamResponse) ProtoReflect() protoreflect.Message
  • func (x *CloseStreamResponse) Reset()
  • func (x *CloseStreamResponse) String() string
• type CloseStreamResponse_builder
  • func (b0 CloseStreamResponse_builder) Build() *CloseStreamResponse
• type CreateStreamRequest
  • func (x *CreateStreamRequest) ClearStreamInfo()
  • func (x *CreateStreamRequest) GetName() string
  • func (x *CreateStreamRequest) GetStreamInfo() string
  • func (x *CreateStreamRequest) HasStreamInfo() bool
  • func (*CreateStreamRequest) ProtoMessage()
  • func (x *CreateStreamRequest) ProtoReflect() protoreflect.Message
  • func (x *CreateStreamRequest) Reset()
  • func (x *CreateStreamRequest) SetName(v string)
  • func (x *CreateStreamRequest) SetStreamInfo(v string)
  • func (x *CreateStreamRequest) String() string
• type CreateStreamRequest_builder
  • func (b0 CreateStreamRequest_builder) Build() *CreateStreamRequest
• type CreateStreamResponse
  • func (*CreateStreamResponse) ProtoMessage()
  • func (x *CreateStreamResponse) ProtoReflect() protoreflect.Message
  • func (x *CreateStreamResponse) Reset()
  • func (x *CreateStreamResponse) String() string
• type CreateStreamResponse_builder
  • func (b0 CreateStreamResponse_builder) Build() *CreateStreamResponse
• type SendStreamPacketRequest
  • func (x *SendStreamPacketRequest) GetData() []byte
  • func (x *SendStreamPacketRequest) GetStreamId() string
  • func (*SendStreamPacketRequest) ProtoMessage()
  • func (x *SendStreamPacketRequest) ProtoReflect() protoreflect.Message
  • func (x *SendStreamPacketRequest) Reset()
  • func (x *SendStreamPacketRequest) SetData(v []byte)
  • func (x *SendStreamPacketRequest) SetStreamId(v string)
  • func (x *SendStreamPacketRequest) String() string
• type SendStreamPacketRequest_builder
  • func (b0 SendStreamPacketRequest_builder) Build() *SendStreamPacketRequest
• type SendStreamPacketResponse
  • func (*SendStreamPacketResponse) ProtoMessage()
  • func (x *SendStreamPacketResponse) ProtoReflect() protoreflect.Message
  • func (x *SendStreamPacketResponse) Reset()
  • func (x *SendStreamPacketResponse) String() string
• type SendStreamPacketResponse_builder
  • func (b0 SendStreamPacketResponse_builder) Build() *SendStreamPacketResponse

Variables

var File_plume_api_streaming_v1_streaming_proto protoreflect.FileDescriptor

Types

type CloseStreamRequest

type CloseStreamRequest struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseStreamRequest) GetStreamId

func (x *CloseStreamRequest) GetStreamId() string

func (*CloseStreamRequest) ProtoMessage

func (*CloseStreamRequest) ProtoMessage()

func (*CloseStreamRequest) ProtoReflect

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

func (*CloseStreamRequest) Reset

func (x *CloseStreamRequest) Reset()

func (*CloseStreamRequest) SetStreamId

func (x *CloseStreamRequest) SetStreamId(v string)

func (*CloseStreamRequest) String

func (x *CloseStreamRequest) String() string

type CloseStreamRequest_builder

type CloseStreamRequest_builder struct {
	StreamId string
	// contains filtered or unexported fields
}

func (CloseStreamRequest_builder) Build

func (b0 CloseStreamRequest_builder) Build() *CloseStreamRequest

type CloseStreamResponse

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

func (*CloseStreamResponse) ProtoMessage

func (*CloseStreamResponse) ProtoMessage()

func (*CloseStreamResponse) ProtoReflect

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

func (*CloseStreamResponse) Reset

func (x *CloseStreamResponse) Reset()

func (*CloseStreamResponse) String

func (x *CloseStreamResponse) String() string

type CloseStreamResponse_builder

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

func (CloseStreamResponse_builder) Build

func (b0 CloseStreamResponse_builder) Build() *CloseStreamResponse

type CreateStreamRequest

type CreateStreamRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Extra information about the stream. Expects a valid JSON string.
	StreamInfo *string `protobuf:"bytes,2,opt,name=stream_info,json=streamInfo,proto3,oneof" json:"stream_info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamRequest) ClearStreamInfo

func (x *CreateStreamRequest) ClearStreamInfo()

func (*CreateStreamRequest) GetName

func (x *CreateStreamRequest) GetName() string

func (*CreateStreamRequest) GetStreamInfo

func (x *CreateStreamRequest) GetStreamInfo() string

func (*CreateStreamRequest) HasStreamInfo

func (x *CreateStreamRequest) HasStreamInfo() bool

func (*CreateStreamRequest) ProtoMessage

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect

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

func (*CreateStreamRequest) Reset

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) SetName

func (x *CreateStreamRequest) SetName(v string)

func (*CreateStreamRequest) SetStreamInfo

func (x *CreateStreamRequest) SetStreamInfo(v string)

func (*CreateStreamRequest) String

func (x *CreateStreamRequest) String() string

type CreateStreamRequest_builder

type CreateStreamRequest_builder struct {
	Name string
	// Extra information about the stream. Expects a valid JSON string.
	StreamInfo *string
	// contains filtered or unexported fields
}

func (CreateStreamRequest_builder) Build

func (b0 CreateStreamRequest_builder) Build() *CreateStreamRequest

type CreateStreamResponse

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

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 CreateStreamResponse_builder

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

func (CreateStreamResponse_builder) Build

func (b0 CreateStreamResponse_builder) Build() *CreateStreamResponse

type SendStreamPacketRequest

type SendStreamPacketRequest struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SendStreamPacketRequest) GetData

func (x *SendStreamPacketRequest) GetData() []byte

func (*SendStreamPacketRequest) GetStreamId

func (x *SendStreamPacketRequest) GetStreamId() string

func (*SendStreamPacketRequest) ProtoMessage

func (*SendStreamPacketRequest) ProtoMessage()

func (*SendStreamPacketRequest) ProtoReflect

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

func (*SendStreamPacketRequest) Reset

func (x *SendStreamPacketRequest) Reset()

func (*SendStreamPacketRequest) SetData

func (x *SendStreamPacketRequest) SetData(v []byte)

func (*SendStreamPacketRequest) SetStreamId

func (x *SendStreamPacketRequest) SetStreamId(v string)

func (*SendStreamPacketRequest) String

func (x *SendStreamPacketRequest) String() string

type SendStreamPacketRequest_builder

type SendStreamPacketRequest_builder struct {
	StreamId string
	Data     []byte
	// contains filtered or unexported fields
}

func (SendStreamPacketRequest_builder) Build

func (b0 SendStreamPacketRequest_builder) Build() *SendStreamPacketRequest

type SendStreamPacketResponse

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

func (*SendStreamPacketResponse) ProtoMessage

func (*SendStreamPacketResponse) ProtoMessage()

func (*SendStreamPacketResponse) ProtoReflect

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

func (*SendStreamPacketResponse) Reset

func (x *SendStreamPacketResponse) Reset()

func (*SendStreamPacketResponse) String

func (x *SendStreamPacketResponse) String() string

type SendStreamPacketResponse_builder

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

func (SendStreamPacketResponse_builder) Build

func (b0 SendStreamPacketResponse_builder) Build() *SendStreamPacketResponse