Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAuthorizeServer(s grpc.ServiceRegistrar, srv AuthorizeServer)
- type AuthorizeClient
- type AuthorizeServer
- type Empty
- type Job
- func (*Job) Descriptor() ([]byte, []int)deprecated
- func (x *Job) GetConfig() *config.Config
- func (x *Job) GetHeaders() map[string]*StringList
- func (x *Job) GetParams() map[string]string
- func (x *Job) GetTask() *tes.Task
- func (x *Job) GetType() Type
- func (*Job) ProtoMessage()
- func (x *Job) ProtoReflect() protoreflect.Message
- func (x *Job) Reset()
- func (x *Job) String() string
- type JobResponse
- func (*JobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobResponse) GetCode() int64
- func (x *JobResponse) GetConfig() *config.Config
- func (x *JobResponse) GetMessage() string
- func (x *JobResponse) GetTask() *tes.Task
- func (x *JobResponse) GetUserId() string
- func (*JobResponse) ProtoMessage()
- func (x *JobResponse) ProtoReflect() protoreflect.Message
- func (x *JobResponse) Reset()
- func (x *JobResponse) String() string
- type StringList
- type Type
- type UnimplementedAuthorizeServer
- type UnsafeAuthorizeServer
Constants ¶
const (
Authorize_PluginAction_FullMethodName = "/proto.Authorize/PluginAction"
)
Variables ¶
var ( Type_name = map[int32]string{ 0: "CREATE", 1: "GET", 2: "CANCEL", } Type_value = map[string]int32{ "CREATE": 0, "GET": 1, "CANCEL": 2, } )
Enum value maps for Type.
var Authorize_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Authorize", HandlerType: (*AuthorizeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PluginAction", Handler: _Authorize_PluginAction_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "plugins/proto/plugin.proto", }
Authorize_ServiceDesc is the grpc.ServiceDesc for Authorize service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_plugins_proto_plugin_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAuthorizeServer ¶
func RegisterAuthorizeServer(s grpc.ServiceRegistrar, srv AuthorizeServer)
Types ¶
type AuthorizeClient ¶
type AuthorizeClient interface {
PluginAction(ctx context.Context, in *Job, opts ...grpc.CallOption) (*JobResponse, error)
}
AuthorizeClient is the client API for Authorize service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuthorizeClient ¶
func NewAuthorizeClient(cc grpc.ClientConnInterface) AuthorizeClient
type AuthorizeServer ¶
type AuthorizeServer interface {
PluginAction(context.Context, *Job) (*JobResponse, error)
}
AuthorizeServer is the server API for Authorize service. All implementations should embed UnimplementedAuthorizeServer for forward compatibility
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type Job ¶
type Job struct {
Headers map[string]*StringList `` /* 141-byte string literal not displayed */
Params map[string]string `` /* 139-byte string literal not displayed */
Config *config.Config `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
Task *tes.Task `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"`
Type Type `protobuf:"varint,5,opt,name=type,proto3,enum=proto.Type" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*Job) Descriptor
deprecated
func (*Job) GetHeaders ¶
func (x *Job) GetHeaders() map[string]*StringList
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) ProtoReflect ¶
func (x *Job) ProtoReflect() protoreflect.Message
type JobResponse ¶
type JobResponse struct {
Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Config *config.Config `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
Task *tes.Task `protobuf:"bytes,4,opt,name=task,proto3" json:"task,omitempty"`
UserId string `protobuf:"bytes,7,opt,name=userId,proto3" json:"userId,omitempty"`
// contains filtered or unexported fields
}
func (*JobResponse) Descriptor
deprecated
func (*JobResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobResponse.ProtoReflect.Descriptor instead.
func (*JobResponse) GetCode ¶
func (x *JobResponse) GetCode() int64
func (*JobResponse) GetConfig ¶
func (x *JobResponse) GetConfig() *config.Config
func (*JobResponse) GetMessage ¶
func (x *JobResponse) GetMessage() string
func (*JobResponse) GetTask ¶
func (x *JobResponse) GetTask() *tes.Task
func (*JobResponse) GetUserId ¶
func (x *JobResponse) GetUserId() string
func (*JobResponse) ProtoMessage ¶
func (*JobResponse) ProtoMessage()
func (*JobResponse) ProtoReflect ¶
func (x *JobResponse) ProtoReflect() protoreflect.Message
func (*JobResponse) Reset ¶
func (x *JobResponse) Reset()
func (*JobResponse) String ¶
func (x *JobResponse) String() string
type StringList ¶
type StringList struct {
Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
func (*StringList) Descriptor
deprecated
func (*StringList) Descriptor() ([]byte, []int)
Deprecated: Use StringList.ProtoReflect.Descriptor instead.
func (*StringList) GetValues ¶
func (x *StringList) GetValues() []string
func (*StringList) ProtoMessage ¶
func (*StringList) ProtoMessage()
func (*StringList) ProtoReflect ¶
func (x *StringList) ProtoReflect() protoreflect.Message
func (*StringList) Reset ¶
func (x *StringList) Reset()
func (*StringList) String ¶
func (x *StringList) String() string
type Type ¶
type Type int32
func (Type) Descriptor ¶
func (Type) Descriptor() protoreflect.EnumDescriptor
func (Type) EnumDescriptor
deprecated
func (Type) Number ¶
func (x Type) Number() protoreflect.EnumNumber
func (Type) Type ¶
func (Type) Type() protoreflect.EnumType
type UnimplementedAuthorizeServer ¶
type UnimplementedAuthorizeServer struct {
}
UnimplementedAuthorizeServer should be embedded to have forward compatible implementations.
func (UnimplementedAuthorizeServer) PluginAction ¶
func (UnimplementedAuthorizeServer) PluginAction(context.Context, *Job) (*JobResponse, error)
type UnsafeAuthorizeServer ¶
type UnsafeAuthorizeServer interface {
// contains filtered or unexported methods
}
UnsafeAuthorizeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthorizeServer will result in compilation errors.