requestservice

package
v0.14.3 Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2023 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 GetRequestStatusesForNamespaceRequest added in v0.11.0 

type GetRequestStatusesForNamespaceRequest 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"`
	// the namespace
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// whether to list only open requests
	// if set, will only return requests in pending and in-progress states for the namespace
	// if not set, will return all known requests for the namespace
	Open bool `protobuf:"varint,4,opt,name=open,proto3" json:"open,omitempty"`
}

func (*GetRequestStatusesForNamespaceRequest) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) Equal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) GetNamespace added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) GetNamespace() string

func (*GetRequestStatusesForNamespaceRequest) GetOpen added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) GetOpen() bool

func (*GetRequestStatusesForNamespaceRequest) GetPageSize added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) GetPageSize() int32

func (*GetRequestStatusesForNamespaceRequest) GetPageToken added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) GetPageToken() string

func (*GetRequestStatusesForNamespaceRequest) GoString added in v0.11.0 

func (this *GetRequestStatusesForNamespaceRequest) GoString() string

func (*GetRequestStatusesForNamespaceRequest) Marshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) MarshalTo added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesForNamespaceRequest) ProtoMessage()

func (*GetRequestStatusesForNamespaceRequest) Reset added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) Reset()

func (*GetRequestStatusesForNamespaceRequest) Size added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) String added in v0.11.0 

func (this *GetRequestStatusesForNamespaceRequest) String() string

func (*GetRequestStatusesForNamespaceRequest) Unmarshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) XXX_DiscardUnknown()

func (*GetRequestStatusesForNamespaceRequest) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceRequest) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesForNamespaceRequest) XXX_Size() int

func (*GetRequestStatusesForNamespaceRequest) XXX_Unmarshal added in v0.11.0 

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

type GetRequestStatusesForNamespaceResponse added in v0.11.0 

type GetRequestStatusesForNamespaceResponse 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 (*GetRequestStatusesForNamespaceResponse) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) Equal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) GetNextPageToken added in v0.11.0 

func (m *GetRequestStatusesForNamespaceResponse) GetNextPageToken() string

func (*GetRequestStatusesForNamespaceResponse) GetRequestStatuses added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) GoString added in v0.11.0 

func (this *GetRequestStatusesForNamespaceResponse) GoString() string

func (*GetRequestStatusesForNamespaceResponse) Marshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) MarshalTo added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesForNamespaceResponse) ProtoMessage()

func (*GetRequestStatusesForNamespaceResponse) Reset added in v0.11.0 

func (m *GetRequestStatusesForNamespaceResponse) Reset()

func (*GetRequestStatusesForNamespaceResponse) Size added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) String added in v0.11.0 

func (this *GetRequestStatusesForNamespaceResponse) String() string

func (*GetRequestStatusesForNamespaceResponse) Unmarshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesForNamespaceResponse) XXX_DiscardUnknown()

func (*GetRequestStatusesForNamespaceResponse) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesForNamespaceResponse) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesForNamespaceResponse) XXX_Size() int

func (*GetRequestStatusesForNamespaceResponse) XXX_Unmarshal added in v0.11.0 

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

type GetRequestStatusesForUserRequest added in v0.11.0 

type GetRequestStatusesForUserRequest 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"`
	// the id of the user
	UserId string `protobuf:"bytes,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	// or the email address of the user
	UserEmail string `protobuf:"bytes,4,opt,name=user_email,json=userEmail,proto3" json:"user_email,omitempty"`
	// whether to list only open requests
	// if set, will only return requests in pending and in-progress states started by the user
	// if not set, will return all known requests started by the user
	Open bool `protobuf:"varint,5,opt,name=open,proto3" json:"open,omitempty"`
}

func (*GetRequestStatusesForUserRequest) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) Equal added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) GetOpen added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) GetOpen() bool

func (*GetRequestStatusesForUserRequest) GetPageSize added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) GetPageSize() int32

func (*GetRequestStatusesForUserRequest) GetPageToken added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) GetPageToken() string

func (*GetRequestStatusesForUserRequest) GetUserEmail added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) GetUserEmail() string

func (*GetRequestStatusesForUserRequest) GetUserId added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) GetUserId() string

func (*GetRequestStatusesForUserRequest) GoString added in v0.11.0 

func (this *GetRequestStatusesForUserRequest) GoString() string

func (*GetRequestStatusesForUserRequest) Marshal added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) MarshalTo added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesForUserRequest) ProtoMessage()

func (*GetRequestStatusesForUserRequest) Reset added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) Reset()

func (*GetRequestStatusesForUserRequest) Size added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) String added in v0.11.0 

func (this *GetRequestStatusesForUserRequest) String() string

func (*GetRequestStatusesForUserRequest) Unmarshal added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) XXX_DiscardUnknown()

func (*GetRequestStatusesForUserRequest) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesForUserRequest) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesForUserRequest) XXX_Size() int

func (*GetRequestStatusesForUserRequest) XXX_Unmarshal added in v0.11.0 

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

type GetRequestStatusesForUserResponse added in v0.11.0 

type GetRequestStatusesForUserResponse 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 (*GetRequestStatusesForUserResponse) Descriptor added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) Equal added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) GetNextPageToken added in v0.11.0 

func (m *GetRequestStatusesForUserResponse) GetNextPageToken() string

func (*GetRequestStatusesForUserResponse) GetRequestStatuses added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) GoString added in v0.11.0 

func (this *GetRequestStatusesForUserResponse) GoString() string

func (*GetRequestStatusesForUserResponse) Marshal added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) MarshalTo added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) ProtoMessage added in v0.11.0 

func (*GetRequestStatusesForUserResponse) ProtoMessage()

func (*GetRequestStatusesForUserResponse) Reset added in v0.11.0 

func (m *GetRequestStatusesForUserResponse) Reset()

func (*GetRequestStatusesForUserResponse) Size added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) String added in v0.11.0 

func (this *GetRequestStatusesForUserResponse) String() string

func (*GetRequestStatusesForUserResponse) Unmarshal added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) XXX_DiscardUnknown added in v0.11.0 

func (m *GetRequestStatusesForUserResponse) XXX_DiscardUnknown()

func (*GetRequestStatusesForUserResponse) XXX_Marshal added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) XXX_Merge added in v0.11.0 

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

func (*GetRequestStatusesForUserResponse) XXX_Size added in v0.11.0 

func (m *GetRequestStatusesForUserResponse) XXX_Size() int

func (*GetRequestStatusesForUserResponse) XXX_Unmarshal added in v0.11.0 

func (m *GetRequestStatusesForUserResponse) 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)
	// GetRequestStatuses lists the statuses started by a user.
	GetRequestStatusesForUser(ctx context.Context, in *GetRequestStatusesForUserRequest, opts ...grpc.CallOption) (*GetRequestStatusesForUserResponse, error)
	// GetRequestStatuses lists the statuses of requests started for a namespace.
	GetRequestStatusesForNamespace(ctx context.Context, in *GetRequestStatusesForNamespaceRequest, opts ...grpc.CallOption) (*GetRequestStatusesForNamespaceResponse, 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)
	// GetRequestStatuses lists the statuses started by a user.
	GetRequestStatusesForUser(context.Context, *GetRequestStatusesForUserRequest) (*GetRequestStatusesForUserResponse, error)
	// GetRequestStatuses lists the statuses of requests started for a namespace.
	GetRequestStatusesForNamespace(context.Context, *GetRequestStatusesForNamespaceRequest) (*GetRequestStatusesForNamespaceResponse, 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)

func (*UnimplementedRequestServiceServer) GetRequestStatusesForNamespace added in v0.11.0 

func (*UnimplementedRequestServiceServer) GetRequestStatusesForNamespace(ctx context.Context, req *GetRequestStatusesForNamespaceRequest) (*GetRequestStatusesForNamespaceResponse, error)

func (*UnimplementedRequestServiceServer) GetRequestStatusesForUser added in v0.11.0 

func (*UnimplementedRequestServiceServer) GetRequestStatusesForUser(ctx context.Context, req *GetRequestStatusesForUserRequest) (*GetRequestStatusesForUserResponse, 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.