proto

package
v0.0.0-...-5ed4748 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Antri_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Antri",
	HandlerType: (*AntriServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddTasks",
			Handler:    _Antri_AddTasks_Handler,
		},
		{
			MethodName: "GetTasks",
			Handler:    _Antri_GetTasks_Handler,
		},
		{
			MethodName: "CommitTasks",
			Handler:    _Antri_CommitTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "antri.proto",
}

Antri_ServiceDesc is the grpc.ServiceDesc for Antri 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_antri_proto protoreflect.FileDescriptor

Functions

func RegisterAntriServer 

func RegisterAntriServer(s grpc.ServiceRegistrar, srv AntriServer)

Types

type AddTasksRequest 

type AddTasksRequest struct {
	Tasks []*NewTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTasksRequest) Descriptor deprecated 

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

Deprecated: Use AddTasksRequest.ProtoReflect.Descriptor instead.

func (*AddTasksRequest) GetTasks 

func (x *AddTasksRequest) GetTasks() []*NewTask

func (*AddTasksRequest) ProtoMessage 

func (*AddTasksRequest) ProtoMessage()

func (*AddTasksRequest) ProtoReflect 

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

func (*AddTasksRequest) Reset 

func (x *AddTasksRequest) Reset()

func (*AddTasksRequest) String 

func (x *AddTasksRequest) String() string

type AddTasksResponse 

type AddTasksResponse struct {
	Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTasksResponse) Descriptor deprecated 

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

Deprecated: Use AddTasksResponse.ProtoReflect.Descriptor instead.

func (*AddTasksResponse) GetResult 

func (x *AddTasksResponse) GetResult() bool

func (*AddTasksResponse) ProtoMessage 

func (*AddTasksResponse) ProtoMessage()

func (*AddTasksResponse) ProtoReflect 

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

func (*AddTasksResponse) Reset 

func (x *AddTasksResponse) Reset()

func (*AddTasksResponse) String 

func (x *AddTasksResponse) String() string

type AntriClient 

type AntriClient interface {
	AddTasks(ctx context.Context, in *AddTasksRequest, opts ...grpc.CallOption) (*AddTasksResponse, error)
	GetTasks(ctx context.Context, in *GetTasksRequest, opts ...grpc.CallOption) (*GetTasksResponse, error)
	CommitTasks(ctx context.Context, in *CommitTasksRequest, opts ...grpc.CallOption) (*CommitTasksResponse, error)
}

AntriClient is the client API for Antri 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 NewAntriClient 

func NewAntriClient(cc grpc.ClientConnInterface) AntriClient

type AntriServer 

type AntriServer interface {
	AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)
	GetTasks(context.Context, *GetTasksRequest) (*GetTasksResponse, error)
	CommitTasks(context.Context, *CommitTasksRequest) (*CommitTasksResponse, error)
	// contains filtered or unexported methods
}

AntriServer is the server API for Antri service. All implementations must embed UnimplementedAntriServer for forward compatibility

type CommitTasksRequest 

type CommitTasksRequest struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTasksRequest) Descriptor deprecated 

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

Deprecated: Use CommitTasksRequest.ProtoReflect.Descriptor instead.

func (*CommitTasksRequest) GetKeys 

func (x *CommitTasksRequest) GetKeys() []string

func (*CommitTasksRequest) ProtoMessage 

func (*CommitTasksRequest) ProtoMessage()

func (*CommitTasksRequest) ProtoReflect 

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

func (*CommitTasksRequest) Reset 

func (x *CommitTasksRequest) Reset()

func (*CommitTasksRequest) String 

func (x *CommitTasksRequest) String() string

type CommitTasksResponse 

type CommitTasksResponse struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*CommitTasksResponse) Descriptor deprecated 

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

Deprecated: Use CommitTasksResponse.ProtoReflect.Descriptor instead.

func (*CommitTasksResponse) GetKeys 

func (x *CommitTasksResponse) GetKeys() []string

func (*CommitTasksResponse) ProtoMessage 

func (*CommitTasksResponse) ProtoMessage()

func (*CommitTasksResponse) ProtoReflect 

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

func (*CommitTasksResponse) Reset 

func (x *CommitTasksResponse) Reset()

func (*CommitTasksResponse) String 

func (x *CommitTasksResponse) String() string

type GetTasksRequest 

type GetTasksRequest struct {
	MaxN uint32 `protobuf:"varint,1,opt,name=maxN,proto3" json:"maxN,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTasksRequest) Descriptor deprecated 

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

Deprecated: Use GetTasksRequest.ProtoReflect.Descriptor instead.

func (*GetTasksRequest) GetMaxN 

func (x *GetTasksRequest) GetMaxN() uint32

func (*GetTasksRequest) ProtoMessage 

func (*GetTasksRequest) ProtoMessage()

func (*GetTasksRequest) ProtoReflect 

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

func (*GetTasksRequest) Reset 

func (x *GetTasksRequest) Reset()

func (*GetTasksRequest) String 

func (x *GetTasksRequest) String() string

type GetTasksResponse 

type GetTasksResponse struct {
	Tasks []*RetrievedTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTasksResponse) Descriptor deprecated 

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

Deprecated: Use GetTasksResponse.ProtoReflect.Descriptor instead.

func (*GetTasksResponse) GetTasks 

func (x *GetTasksResponse) GetTasks() []*RetrievedTask

func (*GetTasksResponse) ProtoMessage 

func (*GetTasksResponse) ProtoMessage()

func (*GetTasksResponse) ProtoReflect 

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

func (*GetTasksResponse) Reset 

func (x *GetTasksResponse) Reset()

func (*GetTasksResponse) String 

func (x *GetTasksResponse) String() string

type NewTask 

type NewTask struct {
	Content        []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	SecondsFromNow uint32 `protobuf:"varint,2,opt,name=secondsFromNow,proto3" json:"secondsFromNow,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTask) Descriptor deprecated 

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

Deprecated: Use NewTask.ProtoReflect.Descriptor instead.

func (*NewTask) GetContent 

func (x *NewTask) GetContent() []byte

func (*NewTask) GetSecondsFromNow 

func (x *NewTask) GetSecondsFromNow() uint32

func (*NewTask) ProtoMessage 

func (*NewTask) ProtoMessage()

func (*NewTask) ProtoReflect 

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

func (*NewTask) Reset 

func (x *NewTask) Reset()

func (*NewTask) String 

func (x *NewTask) String() string

type RetrievedTask 

type RetrievedTask struct {
	Key         string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Content     []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	RetryNumber int32  `protobuf:"varint,3,opt,name=retryNumber,proto3" json:"retryNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrievedTask) Descriptor deprecated 

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

Deprecated: Use RetrievedTask.ProtoReflect.Descriptor instead.

func (*RetrievedTask) GetContent 

func (x *RetrievedTask) GetContent() []byte

func (*RetrievedTask) GetKey 

func (x *RetrievedTask) GetKey() string

func (*RetrievedTask) GetRetryNumber 

func (x *RetrievedTask) GetRetryNumber() int32

func (*RetrievedTask) ProtoMessage 

func (*RetrievedTask) ProtoMessage()

func (*RetrievedTask) ProtoReflect 

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

func (*RetrievedTask) Reset 

func (x *RetrievedTask) Reset()

func (*RetrievedTask) String 

func (x *RetrievedTask) String() string

type UnimplementedAntriServer 

type UnimplementedAntriServer struct {
}

UnimplementedAntriServer must be embedded to have forward compatible implementations.

func (UnimplementedAntriServer) AddTasks 

func (UnimplementedAntriServer) AddTasks(context.Context, *AddTasksRequest) (*AddTasksResponse, error)

func (UnimplementedAntriServer) CommitTasks 

func (UnimplementedAntriServer) CommitTasks(context.Context, *CommitTasksRequest) (*CommitTasksResponse, error)

func (UnimplementedAntriServer) GetTasks 

func (UnimplementedAntriServer) GetTasks(context.Context, *GetTasksRequest) (*GetTasksResponse, error)

type UnsafeAntriServer 

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

UnsafeAntriServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AntriServer 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.