synchronization

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: Jan 13, 2022 License: MIT Imports: 13 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_service_synchronization_synchronization_proto protoreflect.FileDescriptor
View Source 
var Synchronization_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "synchronization.Synchronization",
	HandlerType: (*SynchronizationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Synchronization_Create_Handler,
		},
		{
			MethodName: "List",
			Handler:    _Synchronization_List_Handler,
		},
		{
			MethodName: "Flush",
			Handler:    _Synchronization_Flush_Handler,
		},
		{
			MethodName: "Pause",
			Handler:    _Synchronization_Pause_Handler,
		},
		{
			MethodName: "Resume",
			Handler:    _Synchronization_Resume_Handler,
		},
		{
			MethodName: "Reset",
			Handler:    _Synchronization_Reset_Handler,
		},
		{
			MethodName: "Terminate",
			Handler:    _Synchronization_Terminate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service/synchronization/synchronization.proto",
}

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

Functions

func RegisterSynchronizationServer 

func RegisterSynchronizationServer(s grpc.ServiceRegistrar, srv SynchronizationServer)

Types

type CreateRequest 

type CreateRequest struct {

	// Prompter is the prompter identifier to use for creating sessions.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Specification is the creation specification.
	Specification *CreationSpecification `protobuf:"bytes,2,opt,name=specification,proto3" json:"specification,omitempty"`
	// contains filtered or unexported fields
}

CreateRequest encodes a request for session creation.

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetPrompter added in v0.12.0 

func (x *CreateRequest) GetPrompter() string

func (*CreateRequest) GetSpecification 

func (x *CreateRequest) GetSpecification() *CreationSpecification

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect added in v0.12.0 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {

	// Session is the resulting session identifier.
	Session string `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

CreateResponse encodes a session creation response.

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) EnsureValid 

func (r *CreateResponse) EnsureValid() error

EnsureValid verifies that a CreateResponse is valid.

func (*CreateResponse) GetSession 

func (x *CreateResponse) GetSession() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect added in v0.12.0 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type CreationSpecification 

type CreationSpecification struct {

	// Alpha is the alpha endpoint URL for the session.
	Alpha *url.URL `protobuf:"bytes,1,opt,name=alpha,proto3" json:"alpha,omitempty"`
	// Beta is the beta endpoint URL for the session.
	Beta *url.URL `protobuf:"bytes,2,opt,name=beta,proto3" json:"beta,omitempty"`
	// Configuration is the base session configuration. It is the result of
	// merging the global configuration (unless disabled), any manually
	// specified configuration file, and any command line configuration
	// parameters.
	Configuration *synchronization.Configuration `protobuf:"bytes,3,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// ConfigurationAlpha is the alpha-specific session configuration. It is
	// determined based on command line configuration parameters.
	ConfigurationAlpha *synchronization.Configuration `protobuf:"bytes,4,opt,name=configurationAlpha,proto3" json:"configurationAlpha,omitempty"`
	// ConfigurationBeta is the beta-specific session configuration. It is
	// determined based on command line configuration parameters.
	ConfigurationBeta *synchronization.Configuration `protobuf:"bytes,5,opt,name=configurationBeta,proto3" json:"configurationBeta,omitempty"`
	// Name is the name for the session object.
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// Labels are the labels for the session object.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Paused indicates whether or not to create the session pre-paused.
	Paused bool `protobuf:"varint,8,opt,name=paused,proto3" json:"paused,omitempty"`
	// contains filtered or unexported fields
}

CreationSpecification contains the metadata required for a new session.

func (*CreationSpecification) Descriptor deprecated 

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

Deprecated: Use CreationSpecification.ProtoReflect.Descriptor instead.

func (*CreationSpecification) GetAlpha 

func (x *CreationSpecification) GetAlpha() *url.URL

func (*CreationSpecification) GetBeta 

func (x *CreationSpecification) GetBeta() *url.URL

func (*CreationSpecification) GetConfiguration 

func (x *CreationSpecification) GetConfiguration() *synchronization.Configuration

func (*CreationSpecification) GetConfigurationAlpha 

func (x *CreationSpecification) GetConfigurationAlpha() *synchronization.Configuration

func (*CreationSpecification) GetConfigurationBeta 

func (x *CreationSpecification) GetConfigurationBeta() *synchronization.Configuration

func (*CreationSpecification) GetLabels 

func (x *CreationSpecification) GetLabels() map[string]string

func (*CreationSpecification) GetName 

func (x *CreationSpecification) GetName() string

func (*CreationSpecification) GetPaused 

func (x *CreationSpecification) GetPaused() bool

func (*CreationSpecification) ProtoMessage 

func (*CreationSpecification) ProtoMessage()

func (*CreationSpecification) ProtoReflect added in v0.12.0 

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

func (*CreationSpecification) Reset 

func (x *CreationSpecification) Reset()

func (*CreationSpecification) String 

func (x *CreationSpecification) String() string

type FlushRequest 

type FlushRequest struct {

	// Prompter is the prompter to use for status message updates.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,2,opt,name=selection,proto3" json:"selection,omitempty"`
	// SkipWait indicates whether or not the operation should avoid blocking.
	SkipWait bool `protobuf:"varint,3,opt,name=skipWait,proto3" json:"skipWait,omitempty"`
	// contains filtered or unexported fields
}

FlushRequest encodes a request to flush sessions.

func (*FlushRequest) Descriptor deprecated 

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

Deprecated: Use FlushRequest.ProtoReflect.Descriptor instead.

func (*FlushRequest) GetPrompter added in v0.12.0 

func (x *FlushRequest) GetPrompter() string

func (*FlushRequest) GetSelection 

func (x *FlushRequest) GetSelection() *selection.Selection

func (*FlushRequest) GetSkipWait 

func (x *FlushRequest) GetSkipWait() bool

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) ProtoReflect added in v0.12.0 

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

func (*FlushRequest) Reset 

func (x *FlushRequest) Reset()

func (*FlushRequest) String 

func (x *FlushRequest) String() string

type FlushResponse 

type FlushResponse struct {
	// contains filtered or unexported fields
}

FlushResponse indicates completion of flush operation(s).

func (*FlushResponse) Descriptor deprecated 

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

Deprecated: Use FlushResponse.ProtoReflect.Descriptor instead.

func (*FlushResponse) EnsureValid 

func (r *FlushResponse) EnsureValid() error

EnsureValid verifies that a FlushResponse is valid.

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) ProtoReflect added in v0.12.0 

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

func (*FlushResponse) Reset 

func (x *FlushResponse) Reset()

func (*FlushResponse) String 

func (x *FlushResponse) String() string

type ListRequest 

type ListRequest struct {

	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	// PreviousStateIndex is the previously seen state index. 0 may be provided
	// to force an immediate state listing.
	PreviousStateIndex uint64 `protobuf:"varint,2,opt,name=previousStateIndex,proto3" json:"previousStateIndex,omitempty"`
	// contains filtered or unexported fields
}

ListRequest encodes a request for session metadata.

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetPreviousStateIndex 

func (x *ListRequest) GetPreviousStateIndex() uint64

func (*ListRequest) GetSelection 

func (x *ListRequest) GetSelection() *selection.Selection

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect added in v0.12.0 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {

	// StateIndex is the state index associated with the session metadata.
	StateIndex uint64 `protobuf:"varint,1,opt,name=stateIndex,proto3" json:"stateIndex,omitempty"`
	// SessionStates are the session metadata states.
	SessionStates []*synchronization.State `protobuf:"bytes,2,rep,name=sessionStates,proto3" json:"sessionStates,omitempty"`
	// contains filtered or unexported fields
}

ListResponse encodes session metadata.

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) EnsureValid 

func (r *ListResponse) EnsureValid() error

EnsureValid verifies that a ListResponse is valid.

func (*ListResponse) GetSessionStates 

func (x *ListResponse) GetSessionStates() []*synchronization.State

func (*ListResponse) GetStateIndex 

func (x *ListResponse) GetStateIndex() uint64

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect added in v0.12.0 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type PauseRequest 

type PauseRequest struct {

	// Prompter is the prompter to use for status message updates.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,2,opt,name=selection,proto3" json:"selection,omitempty"`
	// contains filtered or unexported fields
}

PauseRequest encodes a request to pause sessions.

func (*PauseRequest) Descriptor deprecated 

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

Deprecated: Use PauseRequest.ProtoReflect.Descriptor instead.

func (*PauseRequest) GetPrompter added in v0.12.0 

func (x *PauseRequest) GetPrompter() string

func (*PauseRequest) GetSelection 

func (x *PauseRequest) GetSelection() *selection.Selection

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) ProtoReflect added in v0.12.0 

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

func (*PauseRequest) Reset 

func (x *PauseRequest) Reset()

func (*PauseRequest) String 

func (x *PauseRequest) String() string

type PauseResponse 

type PauseResponse struct {
	// contains filtered or unexported fields
}

PauseResponse indicates completion of pause operation(s).

func (*PauseResponse) Descriptor deprecated 

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

Deprecated: Use PauseResponse.ProtoReflect.Descriptor instead.

func (*PauseResponse) EnsureValid 

func (r *PauseResponse) EnsureValid() error

EnsureValid verifies that a PauseResponse is valid.

func (*PauseResponse) ProtoMessage 

func (*PauseResponse) ProtoMessage()

func (*PauseResponse) ProtoReflect added in v0.12.0 

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

func (*PauseResponse) Reset 

func (x *PauseResponse) Reset()

func (*PauseResponse) String 

func (x *PauseResponse) String() string

type ResetRequest added in v0.10.2 

type ResetRequest struct {

	// Prompter is the prompter identifier to use for resetting sessions.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,2,opt,name=selection,proto3" json:"selection,omitempty"`
	// contains filtered or unexported fields
}

ResetRequest encodes a request to reset sessions.

func (*ResetRequest) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.

func (*ResetRequest) GetPrompter added in v0.12.0 

func (x *ResetRequest) GetPrompter() string

func (*ResetRequest) GetSelection added in v0.10.2 

func (x *ResetRequest) GetSelection() *selection.Selection

func (*ResetRequest) ProtoMessage added in v0.10.2 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) ProtoReflect added in v0.12.0 

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

func (*ResetRequest) Reset added in v0.10.2 

func (x *ResetRequest) Reset()

func (*ResetRequest) String added in v0.10.2 

func (x *ResetRequest) String() string

type ResetResponse added in v0.10.2 

type ResetResponse struct {
	// contains filtered or unexported fields
}

ResetResponse indicates completion of reset operation(s).

func (*ResetResponse) Descriptor deprecated added in v0.10.2 

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

Deprecated: Use ResetResponse.ProtoReflect.Descriptor instead.

func (*ResetResponse) EnsureValid added in v0.10.2 

func (r *ResetResponse) EnsureValid() error

EnsureValid verifies that a ResetResponse is valid.

func (*ResetResponse) ProtoMessage added in v0.10.2 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) ProtoReflect added in v0.12.0 

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

func (*ResetResponse) Reset added in v0.10.2 

func (x *ResetResponse) Reset()

func (*ResetResponse) String added in v0.10.2 

func (x *ResetResponse) String() string

type ResumeRequest 

type ResumeRequest struct {

	// Prompter is the prompter identifier to use for resuming sessions.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,2,opt,name=selection,proto3" json:"selection,omitempty"`
	// contains filtered or unexported fields
}

ResumeRequest encodes a request to resume sessions.

func (*ResumeRequest) Descriptor deprecated 

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

Deprecated: Use ResumeRequest.ProtoReflect.Descriptor instead.

func (*ResumeRequest) GetPrompter added in v0.12.0 

func (x *ResumeRequest) GetPrompter() string

func (*ResumeRequest) GetSelection 

func (x *ResumeRequest) GetSelection() *selection.Selection

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) ProtoReflect added in v0.12.0 

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

func (*ResumeRequest) Reset 

func (x *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (x *ResumeRequest) String() string

type ResumeResponse 

type ResumeResponse struct {
	// contains filtered or unexported fields
}

ResumeResponse indicates completion of resume operation(s).

func (*ResumeResponse) Descriptor deprecated 

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

Deprecated: Use ResumeResponse.ProtoReflect.Descriptor instead.

func (*ResumeResponse) EnsureValid 

func (r *ResumeResponse) EnsureValid() error

EnsureValid verifies that a ResumeResponse is valid.

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) ProtoReflect added in v0.12.0 

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

func (*ResumeResponse) Reset 

func (x *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (x *ResumeResponse) String() string

type Server 

type Server struct {
	// UnimplementedSynchronizationServer is the required base implementation.
	UnimplementedSynchronizationServer
	// contains filtered or unexported fields
}

Server provides an implementation of the Synchronization service.

func NewServer 

func NewServer(manager *synchronization.Manager) *Server

NewServer creates a new session server.

func (*Server) Create 

func (s *Server) Create(ctx context.Context, request *CreateRequest) (*CreateResponse, error)

Create creates a new session.

func (*Server) Flush 

func (s *Server) Flush(ctx context.Context, request *FlushRequest) (*FlushResponse, error)

Flush flushes sessions.

func (*Server) List 

func (s *Server) List(ctx context.Context, request *ListRequest) (*ListResponse, error)

List queries session status.

func (*Server) Pause 

func (s *Server) Pause(ctx context.Context, request *PauseRequest) (*PauseResponse, error)

Pause pauses sessions.

func (*Server) Reset added in v0.10.2 

func (s *Server) Reset(ctx context.Context, request *ResetRequest) (*ResetResponse, error)

Reset resets sessions.

func (*Server) Resume 

func (s *Server) Resume(ctx context.Context, request *ResumeRequest) (*ResumeResponse, error)

Resume resumes sessions.

func (*Server) Terminate 

func (s *Server) Terminate(ctx context.Context, request *TerminateRequest) (*TerminateResponse, error)

Terminate terminates sessions.

type SynchronizationClient 

type SynchronizationClient interface {
	// Create creates a new session.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// List returns metadata for existing sessions.
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	// Flush flushes sessions.
	Flush(ctx context.Context, in *FlushRequest, opts ...grpc.CallOption) (*FlushResponse, error)
	// Pause pauses sessions.
	Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*PauseResponse, error)
	// Resume resumes paused or disconnected sessions.
	Resume(ctx context.Context, in *ResumeRequest, opts ...grpc.CallOption) (*ResumeResponse, error)
	// Reset resets sessions' histories.
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)
	// Terminate terminates sessions.
	Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
}

SynchronizationClient is the client API for Synchronization 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 NewSynchronizationClient 

func NewSynchronizationClient(cc grpc.ClientConnInterface) SynchronizationClient

type SynchronizationServer 

type SynchronizationServer interface {
	// Create creates a new session.
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// List returns metadata for existing sessions.
	List(context.Context, *ListRequest) (*ListResponse, error)
	// Flush flushes sessions.
	Flush(context.Context, *FlushRequest) (*FlushResponse, error)
	// Pause pauses sessions.
	Pause(context.Context, *PauseRequest) (*PauseResponse, error)
	// Resume resumes paused or disconnected sessions.
	Resume(context.Context, *ResumeRequest) (*ResumeResponse, error)
	// Reset resets sessions' histories.
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)
	// Terminate terminates sessions.
	Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// contains filtered or unexported methods
}

SynchronizationServer is the server API for Synchronization service. All implementations must embed UnimplementedSynchronizationServer for forward compatibility

type TerminateRequest 

type TerminateRequest struct {

	// Prompter is the prompter to use for status message updates.
	Prompter string `protobuf:"bytes,1,opt,name=prompter,proto3" json:"prompter,omitempty"`
	// Selection is the session selection criteria.
	Selection *selection.Selection `protobuf:"bytes,2,opt,name=selection,proto3" json:"selection,omitempty"`
	// contains filtered or unexported fields
}

TerminateRequest encodes a request to terminate sessions.

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetPrompter added in v0.12.0 

func (x *TerminateRequest) GetPrompter() string

func (*TerminateRequest) GetSelection 

func (x *TerminateRequest) GetSelection() *selection.Selection

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect added in v0.12.0 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

type TerminateResponse struct {
	// contains filtered or unexported fields
}

TerminateResponse indicates completion of termination operation(s).

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) EnsureValid 

func (r *TerminateResponse) EnsureValid() error

EnsureValid verifies that a TerminateResponse is valid.

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect added in v0.12.0 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type UnimplementedSynchronizationServer added in v0.10.1 

type UnimplementedSynchronizationServer struct {
}

UnimplementedSynchronizationServer must be embedded to have forward compatible implementations.

func (UnimplementedSynchronizationServer) Create added in v0.10.1 

func (UnimplementedSynchronizationServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedSynchronizationServer) Flush added in v0.10.1 

func (UnimplementedSynchronizationServer) Flush(context.Context, *FlushRequest) (*FlushResponse, error)

func (UnimplementedSynchronizationServer) List added in v0.10.1 

func (UnimplementedSynchronizationServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedSynchronizationServer) Pause added in v0.10.1 

func (UnimplementedSynchronizationServer) Pause(context.Context, *PauseRequest) (*PauseResponse, error)

func (UnimplementedSynchronizationServer) Reset added in v0.10.2 

func (UnimplementedSynchronizationServer) Reset(context.Context, *ResetRequest) (*ResetResponse, error)

func (UnimplementedSynchronizationServer) Resume added in v0.10.1 

func (UnimplementedSynchronizationServer) Resume(context.Context, *ResumeRequest) (*ResumeResponse, error)

func (UnimplementedSynchronizationServer) Terminate added in v0.10.1 

func (UnimplementedSynchronizationServer) Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)

type UnsafeSynchronizationServer added in v0.12.0 

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

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