proto

package
v2.0.22 Latest Latest
Warning

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

 Go to latest Published: May 27, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ActionController_Ping_FullMethodName      = "/mediaserveractionproto.ActionController/Ping"
	ActionController_GetParams_FullMethodName = "/mediaserveractionproto.ActionController/GetParams"
	ActionController_Action_FullMethodName    = "/mediaserveractionproto.ActionController/Action"
)
View Source 
const (
	ActionDispatcher_Ping_FullMethodName             = "/mediaserveractionproto.ActionDispatcher/Ping"
	ActionDispatcher_AddController_FullMethodName    = "/mediaserveractionproto.ActionDispatcher/AddController"
	ActionDispatcher_RemoveController_FullMethodName = "/mediaserveractionproto.ActionDispatcher/RemoveController"
)

Variables

View Source 
var ActionController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserveractionproto.ActionController",
	HandlerType: (*ActionControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ActionController_Ping_Handler,
		},
		{
			MethodName: "GetParams",
			Handler:    _ActionController_GetParams_Handler,
		},
		{
			MethodName: "Action",
			Handler:    _ActionController_Action_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "actioncontroller.proto",
}

ActionController_ServiceDesc is the grpc.ServiceDesc for ActionController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var ActionDispatcher_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mediaserveractionproto.ActionDispatcher",
	HandlerType: (*ActionDispatcherServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _ActionDispatcher_Ping_Handler,
		},
		{
			MethodName: "AddController",
			Handler:    _ActionDispatcher_AddController_Handler,
		},
		{
			MethodName: "RemoveController",
			Handler:    _ActionDispatcher_RemoveController_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "actioncontroller.proto",
}

ActionDispatcher_ServiceDesc is the grpc.ServiceDesc for ActionDispatcher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_action_proto protoreflect.FileDescriptor
View Source 
var File_actioncontroller_proto protoreflect.FileDescriptor

Functions

func RegisterActionControllerServer 

func RegisterActionControllerServer(s grpc.ServiceRegistrar, srv ActionControllerServer)

func RegisterActionDispatcherServer 

func RegisterActionDispatcherServer(s grpc.ServiceRegistrar, srv ActionDispatcherServer)

Types

type ActionControllerClient 

type ActionControllerClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	GetParams(ctx context.Context, in *ParamsParam, opts ...grpc.CallOption) (*proto.StringList, error)
	Action(ctx context.Context, in *ActionParam, opts ...grpc.CallOption) (*proto1.Cache, error)
}

ActionControllerClient is the client API for ActionController 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 NewActionControllerClient 

func NewActionControllerClient(cc grpc.ClientConnInterface) ActionControllerClient

type ActionControllerServer 

type ActionControllerServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	GetParams(context.Context, *ParamsParam) (*proto.StringList, error)
	Action(context.Context, *ActionParam) (*proto1.Cache, error)
	// contains filtered or unexported methods
}

ActionControllerServer is the server API for ActionController service. All implementations must embed UnimplementedActionControllerServer for forward compatibility

type ActionDispatcherClient 

type ActionDispatcherClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
	AddController(ctx context.Context, in *ActionDispatcherParam, opts ...grpc.CallOption) (*DispatcherDefaultResponse, error)
	RemoveController(ctx context.Context, in *ActionDispatcherParam, opts ...grpc.CallOption) (*proto.DefaultResponse, error)
}

ActionDispatcherClient is the client API for ActionDispatcher 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 NewActionDispatcherClient 

func NewActionDispatcherClient(cc grpc.ClientConnInterface) ActionDispatcherClient

type ActionDispatcherParam 

type ActionDispatcherParam struct {
	Type        string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Action      []string `protobuf:"bytes,2,rep,name=action,proto3" json:"action,omitempty"`
	Host        *string  `protobuf:"bytes,3,opt,name=host,proto3,oneof" json:"host,omitempty"`
	Port        uint32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	Concurrency uint32   `protobuf:"varint,5,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDispatcherParam) Descriptor deprecated 

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

Deprecated: Use ActionDispatcherParam.ProtoReflect.Descriptor instead.

func (*ActionDispatcherParam) GetAction 

func (x *ActionDispatcherParam) GetAction() []string

func (*ActionDispatcherParam) GetConcurrency 

func (x *ActionDispatcherParam) GetConcurrency() uint32

func (*ActionDispatcherParam) GetHost 

func (x *ActionDispatcherParam) GetHost() string

func (*ActionDispatcherParam) GetPort 

func (x *ActionDispatcherParam) GetPort() uint32

func (*ActionDispatcherParam) GetType 

func (x *ActionDispatcherParam) GetType() string

func (*ActionDispatcherParam) ProtoMessage 

func (*ActionDispatcherParam) ProtoMessage()

func (*ActionDispatcherParam) ProtoReflect 

func (x *ActionDispatcherParam) ProtoReflect() protoreflect.Message

func (*ActionDispatcherParam) Reset 

func (x *ActionDispatcherParam) Reset()

func (*ActionDispatcherParam) String 

func (x *ActionDispatcherParam) String() string

type ActionDispatcherServer 

type ActionDispatcherServer interface {
	Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)
	AddController(context.Context, *ActionDispatcherParam) (*DispatcherDefaultResponse, error)
	RemoveController(context.Context, *ActionDispatcherParam) (*proto.DefaultResponse, error)
	// contains filtered or unexported methods
}

ActionDispatcherServer is the server API for ActionDispatcher service. All implementations must embed UnimplementedActionDispatcherServer for forward compatibility

type ActionParam 

type ActionParam struct {
	Item    *proto.Item       `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	Action  string            `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	Params  map[string]string `` /* 153-byte string literal not displayed */
	Storage *proto.Storage    `protobuf:"bytes,4,opt,name=storage,proto3" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionParam) Descriptor deprecated 

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

Deprecated: Use ActionParam.ProtoReflect.Descriptor instead.

func (*ActionParam) GetAction 

func (x *ActionParam) GetAction() string

func (*ActionParam) GetItem 

func (x *ActionParam) GetItem() *proto.Item

func (*ActionParam) GetParams 

func (x *ActionParam) GetParams() map[string]string

func (*ActionParam) GetStorage added in v2.0.9 

func (x *ActionParam) GetStorage() *proto.Storage

func (*ActionParam) ProtoMessage 

func (*ActionParam) ProtoMessage()

func (*ActionParam) ProtoReflect 

func (x *ActionParam) ProtoReflect() protoreflect.Message

func (*ActionParam) Reset 

func (x *ActionParam) Reset()

func (*ActionParam) String 

func (x *ActionParam) String() string

type ActionResponse 

type ActionResponse struct {

	// Types that are assignable to ActionResponse:
	//
	//	*ActionResponse_Response
	//	*ActionResponse_Cache
	ActionResponse isActionResponse_ActionResponse `protobuf_oneof:"actionResponse"`
	// contains filtered or unexported fields
}

func (*ActionResponse) Descriptor deprecated 

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

Deprecated: Use ActionResponse.ProtoReflect.Descriptor instead.

func (*ActionResponse) GetActionResponse 

func (m *ActionResponse) GetActionResponse() isActionResponse_ActionResponse

func (*ActionResponse) GetCache 

func (x *ActionResponse) GetCache() *proto.Cache

func (*ActionResponse) GetResponse 

func (x *ActionResponse) GetResponse() *proto1.DefaultResponse

func (*ActionResponse) ProtoMessage 

func (*ActionResponse) ProtoMessage()

func (*ActionResponse) ProtoReflect 

func (x *ActionResponse) ProtoReflect() protoreflect.Message

func (*ActionResponse) Reset 

func (x *ActionResponse) Reset()

func (*ActionResponse) String 

func (x *ActionResponse) String() string

type ActionResponse_Cache 

type ActionResponse_Cache struct {
	Cache *proto.Cache `protobuf:"bytes,3,opt,name=cache,proto3,oneof"`
}

type ActionResponse_Response 

type ActionResponse_Response struct {
	Response *proto1.DefaultResponse `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type DispatcherDefaultResponse 

type DispatcherDefaultResponse struct {
	Response     *proto.DefaultResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	NextCallWait int64                  `protobuf:"varint,4,opt,name=nextCallWait,proto3" json:"nextCallWait,omitempty"`
	// contains filtered or unexported fields
}

func (*DispatcherDefaultResponse) Descriptor deprecated 

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

Deprecated: Use DispatcherDefaultResponse.ProtoReflect.Descriptor instead.

func (*DispatcherDefaultResponse) GetNextCallWait 

func (x *DispatcherDefaultResponse) GetNextCallWait() int64

func (*DispatcherDefaultResponse) GetResponse 

func (x *DispatcherDefaultResponse) GetResponse() *proto.DefaultResponse

func (*DispatcherDefaultResponse) ProtoMessage 

func (*DispatcherDefaultResponse) ProtoMessage()

func (*DispatcherDefaultResponse) ProtoReflect 

func (x *DispatcherDefaultResponse) ProtoReflect() protoreflect.Message

func (*DispatcherDefaultResponse) Reset 

func (x *DispatcherDefaultResponse) Reset()

func (*DispatcherDefaultResponse) String 

func (x *DispatcherDefaultResponse) String() string

type ParamsParam added in v2.0.6 

type ParamsParam struct {
	Type   string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Action string `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ParamsParam) Descriptor deprecated added in v2.0.6 

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

Deprecated: Use ParamsParam.ProtoReflect.Descriptor instead.

func (*ParamsParam) GetAction added in v2.0.6 

func (x *ParamsParam) GetAction() string

func (*ParamsParam) GetType added in v2.0.7 

func (x *ParamsParam) GetType() string

func (*ParamsParam) ProtoMessage added in v2.0.6 

func (*ParamsParam) ProtoMessage()

func (*ParamsParam) ProtoReflect added in v2.0.6 

func (x *ParamsParam) ProtoReflect() protoreflect.Message

func (*ParamsParam) Reset added in v2.0.6 

func (x *ParamsParam) Reset()

func (*ParamsParam) String added in v2.0.6 

func (x *ParamsParam) String() string

type UnimplementedActionControllerServer 

type UnimplementedActionControllerServer struct {
}

UnimplementedActionControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedActionControllerServer) Action 

func (UnimplementedActionControllerServer) Action(context.Context, *ActionParam) (*proto1.Cache, error)

func (UnimplementedActionControllerServer) GetParams 

func (UnimplementedActionControllerServer) GetParams(context.Context, *ParamsParam) (*proto.StringList, error)

func (UnimplementedActionControllerServer) Ping 

func (UnimplementedActionControllerServer) Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)

type UnimplementedActionDispatcherServer 

type UnimplementedActionDispatcherServer struct {
}

UnimplementedActionDispatcherServer must be embedded to have forward compatible implementations.

func (UnimplementedActionDispatcherServer) AddController 

func (UnimplementedActionDispatcherServer) AddController(context.Context, *ActionDispatcherParam) (*DispatcherDefaultResponse, error)

func (UnimplementedActionDispatcherServer) Ping 

func (UnimplementedActionDispatcherServer) Ping(context.Context, *emptypb.Empty) (*proto.DefaultResponse, error)

func (UnimplementedActionDispatcherServer) RemoveController 

func (UnimplementedActionDispatcherServer) RemoveController(context.Context, *ActionDispatcherParam) (*proto.DefaultResponse, error)

type UnsafeActionControllerServer 

type UnsafeActionControllerServer interface {
	// contains filtered or unexported methods
}

UnsafeActionControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionControllerServer will result in compilation errors.

type UnsafeActionDispatcherServer 

type UnsafeActionDispatcherServer interface {
	// contains filtered or unexported methods
}

UnsafeActionDispatcherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionDispatcherServer will result in compilation errors.

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.