Documentation
¶
Index ¶
- func AdaptBuilder(t Builder) *rpc.Interface
- func AdaptStream(t Stream) *rpc.Interface
- type Builder
- type BuilderBuildFromTar
- type BuilderBuildFromTarArgs
- func (v *BuilderBuildFromTarArgs) Application() string
- func (v *BuilderBuildFromTarArgs) HasApplication() bool
- func (v *BuilderBuildFromTarArgs) HasStatus() bool
- func (v *BuilderBuildFromTarArgs) HasTardata() bool
- func (v *BuilderBuildFromTarArgs) MarshalCBOR() ([]byte, error)
- func (v *BuilderBuildFromTarArgs) MarshalJSON() ([]byte, error)
- func (v *BuilderBuildFromTarArgs) Status() *stream.SendStreamClient[*Status]
- func (v *BuilderBuildFromTarArgs) Tardata() *stream.RecvStreamClient[[]byte]
- func (v *BuilderBuildFromTarArgs) UnmarshalCBOR(data []byte) error
- func (v *BuilderBuildFromTarArgs) UnmarshalJSON(data []byte) error
- type BuilderBuildFromTarResults
- func (v *BuilderBuildFromTarResults) MarshalCBOR() ([]byte, error)
- func (v *BuilderBuildFromTarResults) MarshalJSON() ([]byte, error)
- func (v *BuilderBuildFromTarResults) SetVersion(version string)
- func (v *BuilderBuildFromTarResults) UnmarshalCBOR(data []byte) error
- func (v *BuilderBuildFromTarResults) UnmarshalJSON(data []byte) error
- type BuilderClient
- type BuilderClientBuildFromTarResults
- type Status
- func (v *Status) HasKind() bool
- func (v *Status) Kind() string
- func (v *Status) MarshalCBOR() ([]byte, error)
- func (v *Status) MarshalJSON() ([]byte, error)
- func (v *Status) SetKind(kind string)
- func (v *Status) UnmarshalCBOR(data []byte) error
- func (v *Status) UnmarshalJSON(data []byte) error
- func (v *Status) Update() StatusUpdate
- type StatusUpdate
- type Stream
- type StreamClient
- type StreamClientRecvResults
- type StreamRecv
- type StreamRecvArgs
- func (v *StreamRecvArgs) Count() int32
- func (v *StreamRecvArgs) HasCount() bool
- func (v *StreamRecvArgs) MarshalCBOR() ([]byte, error)
- func (v *StreamRecvArgs) MarshalJSON() ([]byte, error)
- func (v *StreamRecvArgs) UnmarshalCBOR(data []byte) error
- func (v *StreamRecvArgs) UnmarshalJSON(data []byte) error
- type StreamRecvResults
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdaptBuilder ¶
func AdaptStream ¶
Types ¶
type Builder ¶
type Builder interface {
BuildFromTar(ctx context.Context, state *BuilderBuildFromTar) error
}
type BuilderBuildFromTar ¶
func (*BuilderBuildFromTar) Args ¶
func (t *BuilderBuildFromTar) Args() *BuilderBuildFromTarArgs
func (*BuilderBuildFromTar) Results ¶
func (t *BuilderBuildFromTar) Results() *BuilderBuildFromTarResults
type BuilderBuildFromTarArgs ¶
type BuilderBuildFromTarArgs struct {
// contains filtered or unexported fields
}
func (*BuilderBuildFromTarArgs) Application ¶
func (v *BuilderBuildFromTarArgs) Application() string
func (*BuilderBuildFromTarArgs) HasApplication ¶
func (v *BuilderBuildFromTarArgs) HasApplication() bool
func (*BuilderBuildFromTarArgs) HasStatus ¶
func (v *BuilderBuildFromTarArgs) HasStatus() bool
func (*BuilderBuildFromTarArgs) HasTardata ¶
func (v *BuilderBuildFromTarArgs) HasTardata() bool
func (*BuilderBuildFromTarArgs) MarshalCBOR ¶
func (v *BuilderBuildFromTarArgs) MarshalCBOR() ([]byte, error)
func (*BuilderBuildFromTarArgs) MarshalJSON ¶
func (v *BuilderBuildFromTarArgs) MarshalJSON() ([]byte, error)
func (*BuilderBuildFromTarArgs) Status ¶
func (v *BuilderBuildFromTarArgs) Status() *stream.SendStreamClient[*Status]
func (*BuilderBuildFromTarArgs) Tardata ¶
func (v *BuilderBuildFromTarArgs) Tardata() *stream.RecvStreamClient[[]byte]
func (*BuilderBuildFromTarArgs) UnmarshalCBOR ¶
func (v *BuilderBuildFromTarArgs) UnmarshalCBOR(data []byte) error
func (*BuilderBuildFromTarArgs) UnmarshalJSON ¶
func (v *BuilderBuildFromTarArgs) UnmarshalJSON(data []byte) error
type BuilderBuildFromTarResults ¶
type BuilderBuildFromTarResults struct {
// contains filtered or unexported fields
}
func (*BuilderBuildFromTarResults) MarshalCBOR ¶
func (v *BuilderBuildFromTarResults) MarshalCBOR() ([]byte, error)
func (*BuilderBuildFromTarResults) MarshalJSON ¶
func (v *BuilderBuildFromTarResults) MarshalJSON() ([]byte, error)
func (*BuilderBuildFromTarResults) SetVersion ¶
func (v *BuilderBuildFromTarResults) SetVersion(version string)
func (*BuilderBuildFromTarResults) UnmarshalCBOR ¶
func (v *BuilderBuildFromTarResults) UnmarshalCBOR(data []byte) error
func (*BuilderBuildFromTarResults) UnmarshalJSON ¶
func (v *BuilderBuildFromTarResults) UnmarshalJSON(data []byte) error
type BuilderClient ¶
func NewBuilderClient ¶
func NewBuilderClient(client rpc.Client) *BuilderClient
func (BuilderClient) BuildFromTar ¶
func (v BuilderClient) BuildFromTar(ctx context.Context, application string, tardata stream.RecvStream[[]byte], status stream.SendStream[*Status]) (*BuilderClientBuildFromTarResults, error)
func (BuilderClient) Export ¶
func (c BuilderClient) Export() Builder
type BuilderClientBuildFromTarResults ¶
type BuilderClientBuildFromTarResults struct {
// contains filtered or unexported fields
}
func (*BuilderClientBuildFromTarResults) HasVersion ¶
func (v *BuilderClientBuildFromTarResults) HasVersion() bool
func (*BuilderClientBuildFromTarResults) Version ¶
func (v *BuilderClientBuildFromTarResults) Version() string
type Status ¶
type Status struct {
// contains filtered or unexported fields
}
func (*Status) MarshalCBOR ¶
func (*Status) MarshalJSON ¶
func (*Status) UnmarshalCBOR ¶
func (*Status) UnmarshalJSON ¶
func (*Status) Update ¶
func (v *Status) Update() StatusUpdate
type StatusUpdate ¶
type StreamClient ¶
func NewStreamClient ¶
func NewStreamClient(client rpc.Client) *StreamClient
func (StreamClient) Export ¶
func (c StreamClient) Export() Stream
func (StreamClient) Recv ¶
func (v StreamClient) Recv(ctx context.Context, count int32) (*StreamClientRecvResults, error)
type StreamClientRecvResults ¶
type StreamClientRecvResults struct {
// contains filtered or unexported fields
}
func (*StreamClientRecvResults) Data ¶
func (v *StreamClientRecvResults) Data() []byte
func (*StreamClientRecvResults) HasData ¶
func (v *StreamClientRecvResults) HasData() bool
type StreamRecv ¶
func (*StreamRecv) Args ¶
func (t *StreamRecv) Args() *StreamRecvArgs
func (*StreamRecv) Results ¶
func (t *StreamRecv) Results() *StreamRecvResults
type StreamRecvArgs ¶
type StreamRecvArgs struct {
// contains filtered or unexported fields
}
func (*StreamRecvArgs) Count ¶
func (v *StreamRecvArgs) Count() int32
func (*StreamRecvArgs) HasCount ¶
func (v *StreamRecvArgs) HasCount() bool
func (*StreamRecvArgs) MarshalCBOR ¶
func (v *StreamRecvArgs) MarshalCBOR() ([]byte, error)
func (*StreamRecvArgs) MarshalJSON ¶
func (v *StreamRecvArgs) MarshalJSON() ([]byte, error)
func (*StreamRecvArgs) UnmarshalCBOR ¶
func (v *StreamRecvArgs) UnmarshalCBOR(data []byte) error
func (*StreamRecvArgs) UnmarshalJSON ¶
func (v *StreamRecvArgs) UnmarshalJSON(data []byte) error
type StreamRecvResults ¶
type StreamRecvResults struct {
// contains filtered or unexported fields
}
func (*StreamRecvResults) MarshalCBOR ¶
func (v *StreamRecvResults) MarshalCBOR() ([]byte, error)
func (*StreamRecvResults) MarshalJSON ¶
func (v *StreamRecvResults) MarshalJSON() ([]byte, error)
func (*StreamRecvResults) SetData ¶
func (v *StreamRecvResults) SetData(data []byte)
func (*StreamRecvResults) UnmarshalCBOR ¶
func (v *StreamRecvResults) UnmarshalCBOR(data []byte) error
func (*StreamRecvResults) UnmarshalJSON ¶
func (v *StreamRecvResults) UnmarshalJSON(data []byte) error
Click to show internal directories.
Click to hide internal directories.