sync

Documentation

Index

• Variables
• func DeregisterSyncEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)
• func RegisterSyncEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedSyncEndpointServer)
• func RegisterSyncEndpointServer(s grpc.ServiceRegistrar, srv SyncEndpointServer)
• type NamedSyncEndpointServer
• type ResyncRequest
  • func (*ResyncRequest) Descriptor() ([]byte, []int)
  • func (x *ResyncRequest) GetDryRun() bool
  • func (x *ResyncRequest) GetPath() string
  • func (x *ResyncRequest) GetTask() *jobs.Task
  • func (*ResyncRequest) ProtoMessage()
  • func (x *ResyncRequest) ProtoReflect() protoreflect.Message
  • func (x *ResyncRequest) Reset()
  • func (x *ResyncRequest) String() string
  • func (this *ResyncRequest) Validate() error
• type ResyncResponse
  • func (*ResyncResponse) Descriptor() ([]byte, []int)
  • func (x *ResyncResponse) GetJsonDiff() string
  • func (x *ResyncResponse) GetSuccess() bool
  • func (x *ResyncResponse) GetTask() *jobs.Task
  • func (*ResyncResponse) ProtoMessage()
  • func (x *ResyncResponse) ProtoReflect() protoreflect.Message
  • func (x *ResyncResponse) Reset()
  • func (x *ResyncResponse) String() string
  • func (this *ResyncResponse) Validate() error
• type SyncEndpointClient
  • func NewSyncEndpointClient(cc grpc.ClientConnInterface) SyncEndpointClient
• type SyncEndpointEnhancedServer
  • func (m SyncEndpointEnhancedServer) TriggerResync(ctx context.Context, r *ResyncRequest) (*ResyncResponse, error)
• type SyncEndpointServer
• type UnimplementedSyncEndpointServer
  • func (UnimplementedSyncEndpointServer) TriggerResync(context.Context, *ResyncRequest) (*ResyncResponse, error)
• type UnsafeSyncEndpointServer

Variables

var File_cells_sync_proto protoreflect.FileDescriptor

var SyncEndpoint_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sync.SyncEndpoint",
	HandlerType: (*SyncEndpointServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "TriggerResync",
			Handler:    _SyncEndpoint_TriggerResync_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cells-sync.proto",
}

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

Functions

func DeregisterSyncEndpointEnhancedServer

func DeregisterSyncEndpointEnhancedServer(s grpc.ServiceRegistrar, name string)

func RegisterSyncEndpointEnhancedServer

func RegisterSyncEndpointEnhancedServer(s grpc.ServiceRegistrar, srv NamedSyncEndpointServer)

func RegisterSyncEndpointServer

func RegisterSyncEndpointServer(s grpc.ServiceRegistrar, srv SyncEndpointServer)

Types

type NamedSyncEndpointServer

type NamedSyncEndpointServer interface {
	SyncEndpointServer
	Name() string
}

type ResyncRequest

type ResyncRequest struct {
	Path   string     `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	DryRun bool       `protobuf:"varint,2,opt,name=DryRun,proto3" json:"DryRun,omitempty"`
	Task   *jobs.Task `protobuf:"bytes,3,opt,name=Task,proto3" json:"Task,omitempty"`
	// contains filtered or unexported fields
}

func (*ResyncRequest) Descriptor

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

Deprecated: Use ResyncRequest.ProtoReflect.Descriptor instead.

func (*ResyncRequest) GetDryRun

func (x *ResyncRequest) GetDryRun() bool

func (*ResyncRequest) GetPath

func (x *ResyncRequest) GetPath() string

func (*ResyncRequest) GetTask

func (x *ResyncRequest) GetTask() *jobs.Task

func (*ResyncRequest) ProtoMessage

func (*ResyncRequest) ProtoMessage()

func (*ResyncRequest) ProtoReflect

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

func (*ResyncRequest) Reset

func (x *ResyncRequest) Reset()

func (*ResyncRequest) String

func (x *ResyncRequest) String() string

func (*ResyncRequest) Validate

func (this *ResyncRequest) Validate() error

type ResyncResponse

type ResyncResponse struct {
	Success  bool       `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	JsonDiff string     `protobuf:"bytes,2,opt,name=JsonDiff,proto3" json:"JsonDiff,omitempty"`
	Task     *jobs.Task `protobuf:"bytes,3,opt,name=Task,proto3" json:"Task,omitempty"`
	// contains filtered or unexported fields
}

func (*ResyncResponse) Descriptor

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

Deprecated: Use ResyncResponse.ProtoReflect.Descriptor instead.

func (*ResyncResponse) GetJsonDiff

func (x *ResyncResponse) GetJsonDiff() string

func (*ResyncResponse) GetSuccess

func (x *ResyncResponse) GetSuccess() bool

func (*ResyncResponse) GetTask

func (x *ResyncResponse) GetTask() *jobs.Task

func (*ResyncResponse) ProtoMessage

func (*ResyncResponse) ProtoMessage()

func (*ResyncResponse) ProtoReflect

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

func (*ResyncResponse) Reset

func (x *ResyncResponse) Reset()

func (*ResyncResponse) String

func (x *ResyncResponse) String() string

func (*ResyncResponse) Validate

func (this *ResyncResponse) Validate() error

type SyncEndpointClient

type SyncEndpointClient interface {
	TriggerResync(ctx context.Context, in *ResyncRequest, opts ...grpc.CallOption) (*ResyncResponse, error)
}

SyncEndpointClient is the client API for SyncEndpoint 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 NewSyncEndpointClient

func NewSyncEndpointClient(cc grpc.ClientConnInterface) SyncEndpointClient

type SyncEndpointEnhancedServer

type SyncEndpointEnhancedServer map[string]NamedSyncEndpointServer

func (SyncEndpointEnhancedServer) TriggerResync

func (m SyncEndpointEnhancedServer) TriggerResync(ctx context.Context, r *ResyncRequest) (*ResyncResponse, error)

type SyncEndpointServer

type SyncEndpointServer interface {
	TriggerResync(context.Context, *ResyncRequest) (*ResyncResponse, error)
	// contains filtered or unexported methods
}

SyncEndpointServer is the server API for SyncEndpoint service. All implementations must embed UnimplementedSyncEndpointServer for forward compatibility

type UnimplementedSyncEndpointServer

type UnimplementedSyncEndpointServer struct {
}

UnimplementedSyncEndpointServer must be embedded to have forward compatible implementations.

func (UnimplementedSyncEndpointServer) TriggerResync

func (UnimplementedSyncEndpointServer) TriggerResync(context.Context, *ResyncRequest) (*ResyncResponse, error)

type UnsafeSyncEndpointServer

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

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