dbadapter

Documentation

Index

• Constants
• Variables
• func RegisterDBAdapterServer(s grpc.ServiceRegistrar, srv DBAdapterServer)
• type DBAdapterClient
  • func NewDBAdapterClient(cc grpc.ClientConnInterface) DBAdapterClient
• type DBAdapterServer
• type UnimplementedDBAdapterServer
  • func (UnimplementedDBAdapterServer) Load(context.Context, *message.Filter) (*message.Tasks, error)
  • func (UnimplementedDBAdapterServer) LoadSorted(context.Context, *message.Filter) (*message.Tasks, error)
  • func (UnimplementedDBAdapterServer) Store(context.Context, *message.Tasks) (*message.Task, error)
• type UnsafeDBAdapterServer

Constants

const DBCode = 100001

Variables

var DBAdapter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "DBAdapter",
	HandlerType: (*DBAdapterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Load",
			Handler:    _DBAdapter_Load_Handler,
		},
		{
			MethodName: "LoadSorted",
			Handler:    _DBAdapter_LoadSorted_Handler,
		},
		{
			MethodName: "Store",
			Handler:    _DBAdapter_Store_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "dbadapter.proto",
}

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

var File_dbadapter_proto protoreflect.FileDescriptor

Functions

func RegisterDBAdapterServer

func RegisterDBAdapterServer(s grpc.ServiceRegistrar, srv DBAdapterServer)

Types

type DBAdapterClient

type DBAdapterClient interface {
	Load(ctx context.Context, in *message.Filter, opts ...grpc.CallOption) (*message.Tasks, error)
	LoadSorted(ctx context.Context, in *message.Filter, opts ...grpc.CallOption) (*message.Tasks, error)
	Store(ctx context.Context, in *message.Tasks, opts ...grpc.CallOption) (*message.Task, error)
}

DBAdapterClient is the client API for DBAdapter 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 NewDBAdapterClient

func NewDBAdapterClient(cc grpc.ClientConnInterface) DBAdapterClient

type DBAdapterServer

type DBAdapterServer interface {
	Load(context.Context, *message.Filter) (*message.Tasks, error)
	LoadSorted(context.Context, *message.Filter) (*message.Tasks, error)
	Store(context.Context, *message.Tasks) (*message.Task, error)
	// contains filtered or unexported methods
}

DBAdapterServer is the server API for DBAdapter service. All implementations must embed UnimplementedDBAdapterServer for forward compatibility

type UnimplementedDBAdapterServer

type UnimplementedDBAdapterServer struct {
}

UnimplementedDBAdapterServer must be embedded to have forward compatible implementations.

func (UnimplementedDBAdapterServer) Load

func (UnimplementedDBAdapterServer) Load(context.Context, *message.Filter) (*message.Tasks, error)

func (UnimplementedDBAdapterServer) LoadSorted

func (UnimplementedDBAdapterServer) LoadSorted(context.Context, *message.Filter) (*message.Tasks, error)

func (UnimplementedDBAdapterServer) Store

func (UnimplementedDBAdapterServer) Store(context.Context, *message.Tasks) (*message.Task, error)

type UnsafeDBAdapterServer

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

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