requestservice

package
v0.20.0 Latest Latest
Warning

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

 Go to latest Published: Mar 22, 2024 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterRequestServiceServer 

func RegisterRequestServiceServer(s *grpc.Server, srv RequestServiceServer)

Types

type GetRequestStatusRequest 

type GetRequestStatusRequest struct {
	// the request id
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

func (*GetRequestStatusRequest) Descriptor 

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

func (*GetRequestStatusRequest) Equal 

func (this *GetRequestStatusRequest) Equal(that interface{}) bool

func (*GetRequestStatusRequest) GetRequestId 

func (m *GetRequestStatusRequest) GetRequestId() string

func (*GetRequestStatusRequest) GoString 

func (this *GetRequestStatusRequest) GoString() string

func (*GetRequestStatusRequest) Marshal 

func (m *GetRequestStatusRequest) Marshal() (dAtA []byte, err error)

func (*GetRequestStatusRequest) MarshalTo 

func (m *GetRequestStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequestStatusRequest) MarshalToSizedBuffer 

func (m *GetRequestStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequestStatusRequest) ProtoMessage 

func (*GetRequestStatusRequest) ProtoMessage()

func (*GetRequestStatusRequest) Reset 

func (m *GetRequestStatusRequest) Reset()

func (*GetRequestStatusRequest) Size 

func (m *GetRequestStatusRequest) Size() (n int)

func (*GetRequestStatusRequest) String 

func (this *GetRequestStatusRequest) String() string

func (*GetRequestStatusRequest) Unmarshal 

func (m *GetRequestStatusRequest) Unmarshal(dAtA []byte) error

func (*GetRequestStatusRequest) XXX_DiscardUnknown 

func (m *GetRequestStatusRequest) XXX_DiscardUnknown()

func (*GetRequestStatusRequest) XXX_Marshal 

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

func (*GetRequestStatusRequest) XXX_Merge 

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

func (*GetRequestStatusRequest) XXX_Size 

func (m *GetRequestStatusRequest) XXX_Size() int

func (*GetRequestStatusRequest) XXX_Unmarshal 

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

type GetRequestStatusResponse 

type GetRequestStatusResponse struct {
	// the request status
	RequestStatus *v1.RequestStatus `protobuf:"bytes,1,opt,name=request_status,json=requestStatus,proto3" json:"request_status,omitempty"`
}

func (*GetRequestStatusResponse) Descriptor 

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

func (*GetRequestStatusResponse) Equal 

func (this *GetRequestStatusResponse) Equal(that interface{}) bool

func (*GetRequestStatusResponse) GetRequestStatus 

func (m *GetRequestStatusResponse) GetRequestStatus() *v1.RequestStatus

func (*GetRequestStatusResponse) GoString 

func (this *GetRequestStatusResponse) GoString() string

func (*GetRequestStatusResponse) Marshal 

func (m *GetRequestStatusResponse) Marshal() (dAtA []byte, err error)

func (*GetRequestStatusResponse) MarshalTo 

func (m *GetRequestStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetRequestStatusResponse) MarshalToSizedBuffer 

func (m *GetRequestStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequestStatusResponse) ProtoMessage 

func (*GetRequestStatusResponse) ProtoMessage()

func (*GetRequestStatusResponse) Reset 

func (m *GetRequestStatusResponse) Reset()

func (*GetRequestStatusResponse) Size 

func (m *GetRequestStatusResponse) Size() (n int)

func (*GetRequestStatusResponse) String 

func (this *GetRequestStatusResponse) String() string

func (*GetRequestStatusResponse) Unmarshal 

func (m *GetRequestStatusResponse) Unmarshal(dAtA []byte) error

func (*GetRequestStatusResponse) XXX_DiscardUnknown 

func (m *GetRequestStatusResponse) XXX_DiscardUnknown()

func (*GetRequestStatusResponse) XXX_Marshal 

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

func (*GetRequestStatusResponse) XXX_Merge 

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

func (*GetRequestStatusResponse) XXX_Size 

func (m *GetRequestStatusResponse) XXX_Size() int

func (*GetRequestStatusResponse) XXX_Unmarshal 

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

type GetRequestStatusesRequest added in v0.11.0 

type GetRequestStatusesRequest struct {
	// the requested size of the page to retrive, defaults to 10
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// the page token
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// whether to list only open requests
	// if set, will only return requests in pending and in-progress states
	// if not set, will return all known requests
	Open bool `protobuf:"varint,3,opt,name=open,proto3" json:"open,omitempty"`
}

func (*GetRequestStatusesRequest) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesRequest) Equal added in v0.11.0 

func (this *GetRequestStatusesRequest) Equal(that interface{}) bool

func (*GetRequestStatusesRequest) GetOpen added in v0.11.0 

func (m *GetRequestStatusesRequest) GetOpen() bool

func (*GetRequestStatusesRequest) GetPageSize added in v0.11.0 

func (m *GetRequestStatusesRequest) GetPageSize() int32

func (*GetRequestStatusesRequest) GetPageToken added in v0.11.0 

func (m *GetRequestStatusesRequest) GetPageToken() string

func (*GetRequestStatusesRequest) GoString added in v0.11.0 

func (this *GetRequestStatusesRequest) GoString() string

func (*GetRequestStatusesRequest) Marshal added in v0.11.0 

func (m *GetRequestStatusesRequest) Marshal() (dAtA []byte, err error)

func (*GetRequestStatusesRequest) MarshalTo added in v0.11.0 

func (m *GetRequestStatusesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequestStatusesRequest) MarshalToSizedBuffer added in v0.11.0 

func (m *GetRequestStatusesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequestStatusesRequest) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesRequest) ProtoMessage()

func (*GetRequestStatusesRequest) Reset added in v0.11.0 

func (m *GetRequestStatusesRequest) Reset()

func (*GetRequestStatusesRequest) Size added in v0.11.0 

func (m *GetRequestStatusesRequest) Size() (n int)

func (*GetRequestStatusesRequest) String added in v0.11.0 

func (this *GetRequestStatusesRequest) String() string

func (*GetRequestStatusesRequest) Unmarshal added in v0.11.0 

func (m *GetRequestStatusesRequest) Unmarshal(dAtA []byte) error

func (*GetRequestStatusesRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesRequest) XXX_DiscardUnknown()

func (*GetRequestStatusesRequest) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesRequest) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesRequest) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesRequest) XXX_Size() int

func (*GetRequestStatusesRequest) XXX_Unmarshal added in v0.11.0 

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

type GetRequestStatusesResponse added in v0.11.0 

type GetRequestStatusesResponse struct {
	// the request statuses
	// the requests will be ordered by the start_time, newest first
	RequestStatuses []*v1.RequestStatus `protobuf:"bytes,1,rep,name=request_statuses,json=requestStatuses,proto3" json:"request_statuses,omitempty"`
	// the next page's token
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*GetRequestStatusesResponse) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesResponse) Equal added in v0.11.0 

func (this *GetRequestStatusesResponse) Equal(that interface{}) bool

func (*GetRequestStatusesResponse) GetNextPageToken added in v0.11.0 

func (m *GetRequestStatusesResponse) GetNextPageToken() string

func (*GetRequestStatusesResponse) GetRequestStatuses added in v0.11.0 

func (m *GetRequestStatusesResponse) GetRequestStatuses() []*v1.RequestStatus

func (*GetRequestStatusesResponse) GoString added in v0.11.0 

func (this *GetRequestStatusesResponse) GoString() string

func (*GetRequestStatusesResponse) Marshal added in v0.11.0 

func (m *GetRequestStatusesResponse) Marshal() (dAtA []byte, err error)

func (*GetRequestStatusesResponse) MarshalTo added in v0.11.0 

func (m *GetRequestStatusesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetRequestStatusesResponse) MarshalToSizedBuffer added in v0.11.0 

func (m *GetRequestStatusesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequestStatusesResponse) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesResponse) ProtoMessage()

func (*GetRequestStatusesResponse) Reset added in v0.11.0 

func (m *GetRequestStatusesResponse) Reset()

func (*GetRequestStatusesResponse) Size added in v0.11.0 

func (m *GetRequestStatusesResponse) Size() (n int)

func (*GetRequestStatusesResponse) String added in v0.11.0 

func (this *GetRequestStatusesResponse) String() string

func (*GetRequestStatusesResponse) Unmarshal added in v0.11.0 

func (m *GetRequestStatusesResponse) Unmarshal(dAtA []byte) error

func (*GetRequestStatusesResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesResponse) XXX_DiscardUnknown()

func (*GetRequestStatusesResponse) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesResponse) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesResponse) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesResponse) XXX_Size() int

func (*GetRequestStatusesResponse) XXX_Unmarshal added in v0.11.0 

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

type RequestServiceClient 

type RequestServiceClient interface {
	// GetRequestStatus get the status of a request.
	GetRequestStatus(ctx context.Context, in *GetRequestStatusRequest, opts ...grpc.CallOption) (*GetRequestStatusResponse, error)
	// GetRequestStatuses lists the statuses of all known requests.
	GetRequestStatuses(ctx context.Context, in *GetRequestStatusesRequest, opts ...grpc.CallOption) (*GetRequestStatusesResponse, error)
}

RequestServiceClient is the client API for RequestService service.

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

func NewRequestServiceClient 

func NewRequestServiceClient(cc grpc.ClientConnInterface) RequestServiceClient

type RequestServiceServer 

type RequestServiceServer interface {
	// GetRequestStatus get the status of a request.
	GetRequestStatus(context.Context, *GetRequestStatusRequest) (*GetRequestStatusResponse, error)
	// GetRequestStatuses lists the statuses of all known requests.
	GetRequestStatuses(context.Context, *GetRequestStatusesRequest) (*GetRequestStatusesResponse, error)
}

RequestServiceServer is the server API for RequestService service.

type UnimplementedRequestServiceServer 

type UnimplementedRequestServiceServer struct {
}

UnimplementedRequestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRequestServiceServer) GetRequestStatus 

func (*UnimplementedRequestServiceServer) GetRequestStatus(ctx context.Context, req *GetRequestStatusRequest) (*GetRequestStatusResponse, error)

func (*UnimplementedRequestServiceServer) GetRequestStatuses added in v0.11.0 

func (*UnimplementedRequestServiceServer) GetRequestStatuses(ctx context.Context, req *GetRequestStatusesRequest) (*GetRequestStatusesResponse, 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.