proto

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterExecutorServer 

func RegisterExecutorServer(s *grpc.Server, srv ExecutorServer)

Types

type CancelCommandRequest 

type CancelCommandRequest struct {
	ExecutionID          string   `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelCommandRequest) Descriptor 

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

func (*CancelCommandRequest) GetExecutionID 

func (m *CancelCommandRequest) GetExecutionID() string

func (*CancelCommandRequest) ProtoMessage 

func (*CancelCommandRequest) ProtoMessage()

func (*CancelCommandRequest) Reset 

func (m *CancelCommandRequest) Reset()

func (*CancelCommandRequest) String 

func (m *CancelCommandRequest) String() string

func (*CancelCommandRequest) XXX_DiscardUnknown 

func (m *CancelCommandRequest) XXX_DiscardUnknown()

func (*CancelCommandRequest) XXX_Marshal 

func (m *CancelCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelCommandRequest) XXX_Merge 

func (m *CancelCommandRequest) XXX_Merge(src proto.Message)

func (*CancelCommandRequest) XXX_Size 

func (m *CancelCommandRequest) XXX_Size() int

func (*CancelCommandRequest) XXX_Unmarshal 

func (m *CancelCommandRequest) XXX_Unmarshal(b []byte) error

type CancelCommandResponse 

type CancelCommandResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CancelCommandResponse) Descriptor 

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

func (*CancelCommandResponse) ProtoMessage 

func (*CancelCommandResponse) ProtoMessage()

func (*CancelCommandResponse) Reset 

func (m *CancelCommandResponse) Reset()

func (*CancelCommandResponse) String 

func (m *CancelCommandResponse) String() string

func (*CancelCommandResponse) XXX_DiscardUnknown 

func (m *CancelCommandResponse) XXX_DiscardUnknown()

func (*CancelCommandResponse) XXX_Marshal 

func (m *CancelCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CancelCommandResponse) XXX_Merge 

func (m *CancelCommandResponse) XXX_Merge(src proto.Message)

func (*CancelCommandResponse) XXX_Size 

func (m *CancelCommandResponse) XXX_Size() int

func (*CancelCommandResponse) XXX_Unmarshal 

func (m *CancelCommandResponse) XXX_Unmarshal(b []byte) error

type ExecutorClient 

type ExecutorClient interface {
	Run(ctx context.Context, in *RunCommandRequest, opts ...grpc.CallOption) (*RunCommandResponse, error)
	Start(ctx context.Context, in *RunCommandRequest, opts ...grpc.CallOption) (*StartResponse, error)
	Wait(ctx context.Context, in *WaitRequest, opts ...grpc.CallOption) (Executor_WaitClient, error)
	Cancel(ctx context.Context, in *CancelCommandRequest, opts ...grpc.CallOption) (*CancelCommandResponse, error)
	IsInstalled(ctx context.Context, in *IsInstalledRequest, opts ...grpc.CallOption) (*IsInstalledResponse, error)
	ShouldBid(ctx context.Context, in *ShouldBidRequest, opts ...grpc.CallOption) (*ShouldBidResponse, error)
	ShouldBidBasedOnUsage(ctx context.Context, in *ShouldBidBasedOnUsageRequest, opts ...grpc.CallOption) (*ShouldBidResponse, error)
	GetOutputStream(ctx context.Context, in *OutputStreamRequest, opts ...grpc.CallOption) (Executor_GetOutputStreamClient, error)
}

ExecutorClient is the client API for Executor service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExecutorClient 

func NewExecutorClient(cc grpc.ClientConnInterface) ExecutorClient

type ExecutorServer 

type ExecutorServer interface {
	Run(context.Context, *RunCommandRequest) (*RunCommandResponse, error)
	Start(context.Context, *RunCommandRequest) (*StartResponse, error)
	Wait(*WaitRequest, Executor_WaitServer) error
	Cancel(context.Context, *CancelCommandRequest) (*CancelCommandResponse, error)
	IsInstalled(context.Context, *IsInstalledRequest) (*IsInstalledResponse, error)
	ShouldBid(context.Context, *ShouldBidRequest) (*ShouldBidResponse, error)
	ShouldBidBasedOnUsage(context.Context, *ShouldBidBasedOnUsageRequest) (*ShouldBidResponse, error)
	GetOutputStream(*OutputStreamRequest, Executor_GetOutputStreamServer) error
}

ExecutorServer is the server API for Executor service.

type Executor_GetOutputStreamClient 

type Executor_GetOutputStreamClient interface {
	Recv() (*OutputStreamResponse, error)
	grpc.ClientStream
}

type Executor_GetOutputStreamServer 

type Executor_GetOutputStreamServer interface {
	Send(*OutputStreamResponse) error
	grpc.ServerStream
}

type Executor_WaitClient 

type Executor_WaitClient interface {
	Recv() (*RunCommandResponse, error)
	grpc.ClientStream
}

type Executor_WaitServer 

type Executor_WaitServer interface {
	Send(*RunCommandResponse) error
	grpc.ServerStream
}

type IsInstalledRequest 

type IsInstalledRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsInstalledRequest) Descriptor 

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

func (*IsInstalledRequest) ProtoMessage 

func (*IsInstalledRequest) ProtoMessage()

func (*IsInstalledRequest) Reset 

func (m *IsInstalledRequest) Reset()

func (*IsInstalledRequest) String 

func (m *IsInstalledRequest) String() string

func (*IsInstalledRequest) XXX_DiscardUnknown 

func (m *IsInstalledRequest) XXX_DiscardUnknown()

func (*IsInstalledRequest) XXX_Marshal 

func (m *IsInstalledRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsInstalledRequest) XXX_Merge 

func (m *IsInstalledRequest) XXX_Merge(src proto.Message)

func (*IsInstalledRequest) XXX_Size 

func (m *IsInstalledRequest) XXX_Size() int

func (*IsInstalledRequest) XXX_Unmarshal 

func (m *IsInstalledRequest) XXX_Unmarshal(b []byte) error

type IsInstalledResponse 

type IsInstalledResponse struct {
	Installed            bool     `protobuf:"varint,1,opt,name=Installed,proto3" json:"Installed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IsInstalledResponse) Descriptor 

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

func (*IsInstalledResponse) GetInstalled 

func (m *IsInstalledResponse) GetInstalled() bool

func (*IsInstalledResponse) ProtoMessage 

func (*IsInstalledResponse) ProtoMessage()

func (*IsInstalledResponse) Reset 

func (m *IsInstalledResponse) Reset()

func (*IsInstalledResponse) String 

func (m *IsInstalledResponse) String() string

func (*IsInstalledResponse) XXX_DiscardUnknown 

func (m *IsInstalledResponse) XXX_DiscardUnknown()

func (*IsInstalledResponse) XXX_Marshal 

func (m *IsInstalledResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsInstalledResponse) XXX_Merge 

func (m *IsInstalledResponse) XXX_Merge(src proto.Message)

func (*IsInstalledResponse) XXX_Size 

func (m *IsInstalledResponse) XXX_Size() int

func (*IsInstalledResponse) XXX_Unmarshal 

func (m *IsInstalledResponse) XXX_Unmarshal(b []byte) error

type OutputStreamRequest 

type OutputStreamRequest struct {
	ExecutionID          string   `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"`
	History              bool     `protobuf:"varint,2,opt,name=History,proto3" json:"History,omitempty"`
	Follow               bool     `protobuf:"varint,3,opt,name=Follow,proto3" json:"Follow,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutputStreamRequest) Descriptor 

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

func (*OutputStreamRequest) GetExecutionID 

func (m *OutputStreamRequest) GetExecutionID() string

func (*OutputStreamRequest) GetFollow 

func (m *OutputStreamRequest) GetFollow() bool

func (*OutputStreamRequest) GetHistory 

func (m *OutputStreamRequest) GetHistory() bool

func (*OutputStreamRequest) ProtoMessage 

func (*OutputStreamRequest) ProtoMessage()

func (*OutputStreamRequest) Reset 

func (m *OutputStreamRequest) Reset()

func (*OutputStreamRequest) String 

func (m *OutputStreamRequest) String() string

func (*OutputStreamRequest) XXX_DiscardUnknown 

func (m *OutputStreamRequest) XXX_DiscardUnknown()

func (*OutputStreamRequest) XXX_Marshal 

func (m *OutputStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutputStreamRequest) XXX_Merge 

func (m *OutputStreamRequest) XXX_Merge(src proto.Message)

func (*OutputStreamRequest) XXX_Size 

func (m *OutputStreamRequest) XXX_Size() int

func (*OutputStreamRequest) XXX_Unmarshal 

func (m *OutputStreamRequest) XXX_Unmarshal(b []byte) error

type OutputStreamResponse 

type OutputStreamResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutputStreamResponse) Descriptor 

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

func (*OutputStreamResponse) GetData 

func (m *OutputStreamResponse) GetData() []byte

func (*OutputStreamResponse) ProtoMessage 

func (*OutputStreamResponse) ProtoMessage()

func (*OutputStreamResponse) Reset 

func (m *OutputStreamResponse) Reset()

func (*OutputStreamResponse) String 

func (m *OutputStreamResponse) String() string

func (*OutputStreamResponse) XXX_DiscardUnknown 

func (m *OutputStreamResponse) XXX_DiscardUnknown()

func (*OutputStreamResponse) XXX_Marshal 

func (m *OutputStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutputStreamResponse) XXX_Merge 

func (m *OutputStreamResponse) XXX_Merge(src proto.Message)

func (*OutputStreamResponse) XXX_Size 

func (m *OutputStreamResponse) XXX_Size() int

func (*OutputStreamResponse) XXX_Unmarshal 

func (m *OutputStreamResponse) XXX_Unmarshal(b []byte) error

type RunCommandRequest 

type RunCommandRequest struct {
	Params               []byte   `protobuf:"bytes,1,opt,name=Params,proto3" json:"Params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunCommandRequest) Descriptor 

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

func (*RunCommandRequest) GetParams 

func (m *RunCommandRequest) GetParams() []byte

func (*RunCommandRequest) ProtoMessage 

func (*RunCommandRequest) ProtoMessage()

func (*RunCommandRequest) Reset 

func (m *RunCommandRequest) Reset()

func (*RunCommandRequest) String 

func (m *RunCommandRequest) String() string

func (*RunCommandRequest) XXX_DiscardUnknown 

func (m *RunCommandRequest) XXX_DiscardUnknown()

func (*RunCommandRequest) XXX_Marshal 

func (m *RunCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunCommandRequest) XXX_Merge 

func (m *RunCommandRequest) XXX_Merge(src proto.Message)

func (*RunCommandRequest) XXX_Size 

func (m *RunCommandRequest) XXX_Size() int

func (*RunCommandRequest) XXX_Unmarshal 

func (m *RunCommandRequest) XXX_Unmarshal(b []byte) error

type RunCommandResponse 

type RunCommandResponse struct {
	Params               []byte   `protobuf:"bytes,1,opt,name=Params,proto3" json:"Params,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RunCommandResponse) Descriptor 

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

func (*RunCommandResponse) GetParams 

func (m *RunCommandResponse) GetParams() []byte

func (*RunCommandResponse) ProtoMessage 

func (*RunCommandResponse) ProtoMessage()

func (*RunCommandResponse) Reset 

func (m *RunCommandResponse) Reset()

func (*RunCommandResponse) String 

func (m *RunCommandResponse) String() string

func (*RunCommandResponse) XXX_DiscardUnknown 

func (m *RunCommandResponse) XXX_DiscardUnknown()

func (*RunCommandResponse) XXX_Marshal 

func (m *RunCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RunCommandResponse) XXX_Merge 

func (m *RunCommandResponse) XXX_Merge(src proto.Message)

func (*RunCommandResponse) XXX_Size 

func (m *RunCommandResponse) XXX_Size() int

func (*RunCommandResponse) XXX_Unmarshal 

func (m *RunCommandResponse) XXX_Unmarshal(b []byte) error

type ShouldBidBasedOnUsageRequest 

type ShouldBidBasedOnUsageRequest struct {
	BidRequest           []byte   `protobuf:"bytes,1,opt,name=BidRequest,proto3" json:"BidRequest,omitempty"`
	Usage                []byte   `protobuf:"bytes,2,opt,name=Usage,proto3" json:"Usage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShouldBidBasedOnUsageRequest) Descriptor 

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

func (*ShouldBidBasedOnUsageRequest) GetBidRequest 

func (m *ShouldBidBasedOnUsageRequest) GetBidRequest() []byte

func (*ShouldBidBasedOnUsageRequest) GetUsage 

func (m *ShouldBidBasedOnUsageRequest) GetUsage() []byte

func (*ShouldBidBasedOnUsageRequest) ProtoMessage 

func (*ShouldBidBasedOnUsageRequest) ProtoMessage()

func (*ShouldBidBasedOnUsageRequest) Reset 

func (m *ShouldBidBasedOnUsageRequest) Reset()

func (*ShouldBidBasedOnUsageRequest) String 

func (m *ShouldBidBasedOnUsageRequest) String() string

func (*ShouldBidBasedOnUsageRequest) XXX_DiscardUnknown 

func (m *ShouldBidBasedOnUsageRequest) XXX_DiscardUnknown()

func (*ShouldBidBasedOnUsageRequest) XXX_Marshal 

func (m *ShouldBidBasedOnUsageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShouldBidBasedOnUsageRequest) XXX_Merge 

func (m *ShouldBidBasedOnUsageRequest) XXX_Merge(src proto.Message)

func (*ShouldBidBasedOnUsageRequest) XXX_Size 

func (m *ShouldBidBasedOnUsageRequest) XXX_Size() int

func (*ShouldBidBasedOnUsageRequest) XXX_Unmarshal 

func (m *ShouldBidBasedOnUsageRequest) XXX_Unmarshal(b []byte) error

type ShouldBidRequest 

type ShouldBidRequest struct {
	BidRequest           []byte   `protobuf:"bytes,1,opt,name=BidRequest,proto3" json:"BidRequest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShouldBidRequest) Descriptor 

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

func (*ShouldBidRequest) GetBidRequest 

func (m *ShouldBidRequest) GetBidRequest() []byte

func (*ShouldBidRequest) ProtoMessage 

func (*ShouldBidRequest) ProtoMessage()

func (*ShouldBidRequest) Reset 

func (m *ShouldBidRequest) Reset()

func (*ShouldBidRequest) String 

func (m *ShouldBidRequest) String() string

func (*ShouldBidRequest) XXX_DiscardUnknown 

func (m *ShouldBidRequest) XXX_DiscardUnknown()

func (*ShouldBidRequest) XXX_Marshal 

func (m *ShouldBidRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShouldBidRequest) XXX_Merge 

func (m *ShouldBidRequest) XXX_Merge(src proto.Message)

func (*ShouldBidRequest) XXX_Size 

func (m *ShouldBidRequest) XXX_Size() int

func (*ShouldBidRequest) XXX_Unmarshal 

func (m *ShouldBidRequest) XXX_Unmarshal(b []byte) error

type ShouldBidResponse 

type ShouldBidResponse struct {
	BidResponse          []byte   `protobuf:"bytes,1,opt,name=BidResponse,proto3" json:"BidResponse,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

shared by both semantic and resource bid

func (*ShouldBidResponse) Descriptor 

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

func (*ShouldBidResponse) GetBidResponse 

func (m *ShouldBidResponse) GetBidResponse() []byte

func (*ShouldBidResponse) ProtoMessage 

func (*ShouldBidResponse) ProtoMessage()

func (*ShouldBidResponse) Reset 

func (m *ShouldBidResponse) Reset()

func (*ShouldBidResponse) String 

func (m *ShouldBidResponse) String() string

func (*ShouldBidResponse) XXX_DiscardUnknown 

func (m *ShouldBidResponse) XXX_DiscardUnknown()

func (*ShouldBidResponse) XXX_Marshal 

func (m *ShouldBidResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShouldBidResponse) XXX_Merge 

func (m *ShouldBidResponse) XXX_Merge(src proto.Message)

func (*ShouldBidResponse) XXX_Size 

func (m *ShouldBidResponse) XXX_Size() int

func (*ShouldBidResponse) XXX_Unmarshal 

func (m *ShouldBidResponse) XXX_Unmarshal(b []byte) error

type StartResponse 

type StartResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartResponse) Descriptor 

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

func (*StartResponse) ProtoMessage 

func (*StartResponse) ProtoMessage()

func (*StartResponse) Reset 

func (m *StartResponse) Reset()

func (*StartResponse) String 

func (m *StartResponse) String() string

func (*StartResponse) XXX_DiscardUnknown 

func (m *StartResponse) XXX_DiscardUnknown()

func (*StartResponse) XXX_Marshal 

func (m *StartResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartResponse) XXX_Merge 

func (m *StartResponse) XXX_Merge(src proto.Message)

func (*StartResponse) XXX_Size 

func (m *StartResponse) XXX_Size() int

func (*StartResponse) XXX_Unmarshal 

func (m *StartResponse) XXX_Unmarshal(b []byte) error

type UnimplementedExecutorServer 

type UnimplementedExecutorServer struct {
}

UnimplementedExecutorServer can be embedded to have forward compatible implementations.

func (*UnimplementedExecutorServer) Cancel 

func (*UnimplementedExecutorServer) Cancel(ctx context.Context, req *CancelCommandRequest) (*CancelCommandResponse, error)

func (*UnimplementedExecutorServer) GetOutputStream 

func (*UnimplementedExecutorServer) GetOutputStream(req *OutputStreamRequest, srv Executor_GetOutputStreamServer) error

func (*UnimplementedExecutorServer) IsInstalled 

func (*UnimplementedExecutorServer) IsInstalled(ctx context.Context, req *IsInstalledRequest) (*IsInstalledResponse, error)

func (*UnimplementedExecutorServer) Run 

func (*UnimplementedExecutorServer) Run(ctx context.Context, req *RunCommandRequest) (*RunCommandResponse, error)

func (*UnimplementedExecutorServer) ShouldBid 

func (*UnimplementedExecutorServer) ShouldBid(ctx context.Context, req *ShouldBidRequest) (*ShouldBidResponse, error)

func (*UnimplementedExecutorServer) ShouldBidBasedOnUsage 

func (*UnimplementedExecutorServer) ShouldBidBasedOnUsage(ctx context.Context, req *ShouldBidBasedOnUsageRequest) (*ShouldBidResponse, error)

func (*UnimplementedExecutorServer) Start 

func (*UnimplementedExecutorServer) Start(ctx context.Context, req *RunCommandRequest) (*StartResponse, error)

func (*UnimplementedExecutorServer) Wait 

func (*UnimplementedExecutorServer) Wait(req *WaitRequest, srv Executor_WaitServer) error

type WaitRequest 

type WaitRequest struct {
	ExecutionID          string   `protobuf:"bytes,1,opt,name=ExecutionID,proto3" json:"ExecutionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WaitRequest) Descriptor 

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

func (*WaitRequest) GetExecutionID 

func (m *WaitRequest) GetExecutionID() string

func (*WaitRequest) ProtoMessage 

func (*WaitRequest) ProtoMessage()

func (*WaitRequest) Reset 

func (m *WaitRequest) Reset()

func (*WaitRequest) String 

func (m *WaitRequest) String() string

func (*WaitRequest) XXX_DiscardUnknown 

func (m *WaitRequest) XXX_DiscardUnknown()

func (*WaitRequest) XXX_Marshal 

func (m *WaitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WaitRequest) XXX_Merge 

func (m *WaitRequest) XXX_Merge(src proto.Message)

func (*WaitRequest) XXX_Size 

func (m *WaitRequest) XXX_Size() int

func (*WaitRequest) XXX_Unmarshal 

func (m *WaitRequest) XXX_Unmarshal(b []byte) error

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.