synchronization

package
v0.11.0-beta1 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2019 License: MIT Imports: 12 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSynchronizationServer 

func RegisterSynchronizationServer(s *grpc.Server, srv SynchronizationServer)

Types

type CreateRequest 

type CreateRequest struct {
	Specification        *CreationSpecification `protobuf:"bytes,1,opt,name=specification,proto3" json:"specification,omitempty"`
	Response             string                 `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) GetResponse 

func (m *CreateRequest) GetResponse() string

func (*CreateRequest) GetSpecification 

func (m *CreateRequest) GetSpecification() *CreationSpecification

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

type CreateResponse 

type CreateResponse struct {
	Session              string   `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Prompt               string   `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) EnsureValid 

func (r *CreateResponse) EnsureValid() error

EnsureValid verifies that a CreateResponse is valid.

func (*CreateResponse) GetMessage 

func (m *CreateResponse) GetMessage() string

func (*CreateResponse) GetPrompt 

func (m *CreateResponse) GetPrompt() string

func (*CreateResponse) GetSession 

func (m *CreateResponse) GetSession() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) String 

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateResponse) XXX_Merge 

func (m *CreateResponse) XXX_Merge(src proto.Message)

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

func (m *CreateResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreationSpecification) Descriptor 

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

func (*CreationSpecification) GetAlpha 

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

func (*CreationSpecification) GetBeta 

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

func (*CreationSpecification) GetConfiguration 

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

func (*CreationSpecification) GetConfigurationAlpha 

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

func (*CreationSpecification) GetConfigurationBeta 

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

func (*CreationSpecification) GetLabels 

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

func (*CreationSpecification) GetName 

func (m *CreationSpecification) GetName() string

func (*CreationSpecification) GetPaused 

func (m *CreationSpecification) GetPaused() bool

func (*CreationSpecification) ProtoMessage 

func (*CreationSpecification) ProtoMessage()

func (*CreationSpecification) Reset 

func (m *CreationSpecification) Reset()

func (*CreationSpecification) String 

func (m *CreationSpecification) String() string

func (*CreationSpecification) XXX_DiscardUnknown 

func (m *CreationSpecification) XXX_DiscardUnknown()

func (*CreationSpecification) XXX_Marshal 

func (m *CreationSpecification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreationSpecification) XXX_Merge 

func (m *CreationSpecification) XXX_Merge(src proto.Message)

func (*CreationSpecification) XXX_Size 

func (m *CreationSpecification) XXX_Size() int

func (*CreationSpecification) XXX_Unmarshal 

func (m *CreationSpecification) XXX_Unmarshal(b []byte) error

type FlushRequest 

type FlushRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	SkipWait             bool                 `protobuf:"varint,2,opt,name=skipWait,proto3" json:"skipWait,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*FlushRequest) Descriptor 

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

func (*FlushRequest) GetSelection 

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

func (*FlushRequest) GetSkipWait 

func (m *FlushRequest) GetSkipWait() bool

func (*FlushRequest) ProtoMessage 

func (*FlushRequest) ProtoMessage()

func (*FlushRequest) Reset 

func (m *FlushRequest) Reset()

func (*FlushRequest) String 

func (m *FlushRequest) String() string

func (*FlushRequest) XXX_DiscardUnknown 

func (m *FlushRequest) XXX_DiscardUnknown()

func (*FlushRequest) XXX_Marshal 

func (m *FlushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushRequest) XXX_Merge 

func (m *FlushRequest) XXX_Merge(src proto.Message)

func (*FlushRequest) XXX_Size 

func (m *FlushRequest) XXX_Size() int

func (*FlushRequest) XXX_Unmarshal 

func (m *FlushRequest) XXX_Unmarshal(b []byte) error

type FlushResponse 

type FlushResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FlushResponse) Descriptor 

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

func (*FlushResponse) EnsureValid 

func (r *FlushResponse) EnsureValid() error

EnsureValid verifies that a FlushResponse is valid.

func (*FlushResponse) GetMessage 

func (m *FlushResponse) GetMessage() string

func (*FlushResponse) ProtoMessage 

func (*FlushResponse) ProtoMessage()

func (*FlushResponse) Reset 

func (m *FlushResponse) Reset()

func (*FlushResponse) String 

func (m *FlushResponse) String() string

func (*FlushResponse) XXX_DiscardUnknown 

func (m *FlushResponse) XXX_DiscardUnknown()

func (*FlushResponse) XXX_Marshal 

func (m *FlushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FlushResponse) XXX_Merge 

func (m *FlushResponse) XXX_Merge(src proto.Message)

func (*FlushResponse) XXX_Size 

func (m *FlushResponse) XXX_Size() int

func (*FlushResponse) XXX_Unmarshal 

func (m *FlushResponse) XXX_Unmarshal(b []byte) error

type ListRequest 

type ListRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	PreviousStateIndex   uint64               `protobuf:"varint,2,opt,name=previousStateIndex,proto3" json:"previousStateIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetPreviousStateIndex 

func (m *ListRequest) GetPreviousStateIndex() uint64

func (*ListRequest) GetSelection 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListRequest) XXX_Merge 

func (m *ListRequest) XXX_Merge(src proto.Message)

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

func (m *ListRequest) XXX_Unmarshal(b []byte) error

type ListResponse 

type ListResponse struct {
	StateIndex           uint64                   `protobuf:"varint,1,opt,name=stateIndex,proto3" json:"stateIndex,omitempty"`
	SessionStates        []*synchronization.State `protobuf:"bytes,2,rep,name=sessionStates,proto3" json:"sessionStates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) EnsureValid 

func (r *ListResponse) EnsureValid() error

EnsureValid verifies that a ListResponse is valid.

func (*ListResponse) GetSessionStates 

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

func (*ListResponse) GetStateIndex 

func (m *ListResponse) GetStateIndex() uint64

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListResponse) XXX_Merge 

func (m *ListResponse) XXX_Merge(src proto.Message)

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

func (m *ListResponse) XXX_Unmarshal(b []byte) error

type PauseRequest 

type PauseRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PauseRequest) Descriptor 

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

func (*PauseRequest) GetSelection 

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

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset 

func (m *PauseRequest) Reset()

func (*PauseRequest) String 

func (m *PauseRequest) String() string

func (*PauseRequest) XXX_DiscardUnknown 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type PauseResponse 

type PauseResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseResponse) Descriptor 

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

func (*PauseResponse) EnsureValid 

func (r *PauseResponse) EnsureValid() error

EnsureValid verifies that a PauseResponse is valid.

func (*PauseResponse) GetMessage 

func (m *PauseResponse) GetMessage() string

func (*PauseResponse) ProtoMessage 

func (*PauseResponse) ProtoMessage()

func (*PauseResponse) Reset 

func (m *PauseResponse) Reset()

func (*PauseResponse) String 

func (m *PauseResponse) String() string

func (*PauseResponse) XXX_DiscardUnknown 

func (m *PauseResponse) XXX_DiscardUnknown()

func (*PauseResponse) XXX_Marshal 

func (m *PauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseResponse) XXX_Merge 

func (m *PauseResponse) XXX_Merge(src proto.Message)

func (*PauseResponse) XXX_Size 

func (m *PauseResponse) XXX_Size() int

func (*PauseResponse) XXX_Unmarshal 

func (m *PauseResponse) XXX_Unmarshal(b []byte) error

type ResetRequest added in v0.10.2 

type ResetRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	Response             string               `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResetRequest) Descriptor added in v0.10.2 

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

func (*ResetRequest) GetResponse added in v0.10.2 

func (m *ResetRequest) GetResponse() string

func (*ResetRequest) GetSelection added in v0.10.2 

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

func (*ResetRequest) ProtoMessage added in v0.10.2 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) Reset added in v0.10.2 

func (m *ResetRequest) Reset()

func (*ResetRequest) String added in v0.10.2 

func (m *ResetRequest) String() string

func (*ResetRequest) XXX_DiscardUnknown added in v0.10.2 

func (m *ResetRequest) XXX_DiscardUnknown()

func (*ResetRequest) XXX_Marshal added in v0.10.2 

func (m *ResetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetRequest) XXX_Merge added in v0.10.2 

func (m *ResetRequest) XXX_Merge(src proto.Message)

func (*ResetRequest) XXX_Size added in v0.10.2 

func (m *ResetRequest) XXX_Size() int

func (*ResetRequest) XXX_Unmarshal added in v0.10.2 

func (m *ResetRequest) XXX_Unmarshal(b []byte) error

type ResetResponse added in v0.10.2 

type ResetResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Prompt               string   `protobuf:"bytes,2,opt,name=prompt,proto3" json:"prompt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetResponse) Descriptor added in v0.10.2 

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

func (*ResetResponse) EnsureValid added in v0.10.2 

func (r *ResetResponse) EnsureValid() error

EnsureValid verifies that a ResetResponse is valid.

func (*ResetResponse) GetMessage added in v0.10.2 

func (m *ResetResponse) GetMessage() string

func (*ResetResponse) GetPrompt added in v0.10.2 

func (m *ResetResponse) GetPrompt() string

func (*ResetResponse) ProtoMessage added in v0.10.2 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) Reset added in v0.10.2 

func (m *ResetResponse) Reset()

func (*ResetResponse) String added in v0.10.2 

func (m *ResetResponse) String() string

func (*ResetResponse) XXX_DiscardUnknown added in v0.10.2 

func (m *ResetResponse) XXX_DiscardUnknown()

func (*ResetResponse) XXX_Marshal added in v0.10.2 

func (m *ResetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetResponse) XXX_Merge added in v0.10.2 

func (m *ResetResponse) XXX_Merge(src proto.Message)

func (*ResetResponse) XXX_Size added in v0.10.2 

func (m *ResetResponse) XXX_Size() int

func (*ResetResponse) XXX_Unmarshal added in v0.10.2 

func (m *ResetResponse) XXX_Unmarshal(b []byte) error

type ResumeRequest 

type ResumeRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	Response             string               `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResumeRequest) Descriptor 

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

func (*ResumeRequest) GetResponse 

func (m *ResumeRequest) GetResponse() string

func (*ResumeRequest) GetSelection 

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

func (*ResumeRequest) ProtoMessage 

func (*ResumeRequest) ProtoMessage()

func (*ResumeRequest) Reset 

func (m *ResumeRequest) Reset()

func (*ResumeRequest) String 

func (m *ResumeRequest) String() string

func (*ResumeRequest) XXX_DiscardUnknown 

func (m *ResumeRequest) XXX_DiscardUnknown()

func (*ResumeRequest) XXX_Marshal 

func (m *ResumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeRequest) XXX_Merge 

func (m *ResumeRequest) XXX_Merge(src proto.Message)

func (*ResumeRequest) XXX_Size 

func (m *ResumeRequest) XXX_Size() int

func (*ResumeRequest) XXX_Unmarshal 

func (m *ResumeRequest) XXX_Unmarshal(b []byte) error

type ResumeResponse 

type ResumeResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Prompt               string   `protobuf:"bytes,2,opt,name=prompt,proto3" json:"prompt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResumeResponse) Descriptor 

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

func (*ResumeResponse) EnsureValid 

func (r *ResumeResponse) EnsureValid() error

EnsureValid verifies that a ResumeResponse is valid.

func (*ResumeResponse) GetMessage 

func (m *ResumeResponse) GetMessage() string

func (*ResumeResponse) GetPrompt 

func (m *ResumeResponse) GetPrompt() string

func (*ResumeResponse) ProtoMessage 

func (*ResumeResponse) ProtoMessage()

func (*ResumeResponse) Reset 

func (m *ResumeResponse) Reset()

func (*ResumeResponse) String 

func (m *ResumeResponse) String() string

func (*ResumeResponse) XXX_DiscardUnknown 

func (m *ResumeResponse) XXX_DiscardUnknown()

func (*ResumeResponse) XXX_Marshal 

func (m *ResumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResumeResponse) XXX_Merge 

func (m *ResumeResponse) XXX_Merge(src proto.Message)

func (*ResumeResponse) XXX_Size 

func (m *ResumeResponse) XXX_Size() int

func (*ResumeResponse) XXX_Unmarshal 

func (m *ResumeResponse) XXX_Unmarshal(b []byte) error

type Server 

type Server struct {
	// 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(stream Synchronization_CreateServer) error

Create creates a new session.

func (*Server) Flush 

func (s *Server) Flush(stream Synchronization_FlushServer) error

Flush flushes sessions.

func (*Server) List 

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

List queries session status.

func (*Server) Pause 

func (s *Server) Pause(stream Synchronization_PauseServer) error

Pause pauses sessions.

func (*Server) Reset added in v0.10.2 

func (s *Server) Reset(stream Synchronization_ResetServer) error

Reset resets sessions.

func (*Server) Resume 

func (s *Server) Resume(stream Synchronization_ResumeServer) error

Resume resumes sessions.

func (*Server) Terminate 

func (s *Server) Terminate(stream Synchronization_TerminateServer) error

Terminate terminates sessions.

type SynchronizationClient 

type SynchronizationClient interface {
	Create(ctx context.Context, opts ...grpc.CallOption) (Synchronization_CreateClient, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Flush(ctx context.Context, opts ...grpc.CallOption) (Synchronization_FlushClient, error)
	Pause(ctx context.Context, opts ...grpc.CallOption) (Synchronization_PauseClient, error)
	Resume(ctx context.Context, opts ...grpc.CallOption) (Synchronization_ResumeClient, error)
	Reset(ctx context.Context, opts ...grpc.CallOption) (Synchronization_ResetClient, error)
	Terminate(ctx context.Context, opts ...grpc.CallOption) (Synchronization_TerminateClient, error)
}

SynchronizationClient is the client API for Synchronization service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSynchronizationClient 

func NewSynchronizationClient(cc *grpc.ClientConn) SynchronizationClient

type SynchronizationServer 

type SynchronizationServer interface {
	Create(Synchronization_CreateServer) error
	List(context.Context, *ListRequest) (*ListResponse, error)
	Flush(Synchronization_FlushServer) error
	Pause(Synchronization_PauseServer) error
	Resume(Synchronization_ResumeServer) error
	Reset(Synchronization_ResetServer) error
	Terminate(Synchronization_TerminateServer) error
}

SynchronizationServer is the server API for Synchronization service.

type Synchronization_CreateClient 

type Synchronization_CreateClient interface {
	Send(*CreateRequest) error
	Recv() (*CreateResponse, error)
	grpc.ClientStream
}

type Synchronization_CreateServer 

type Synchronization_CreateServer interface {
	Send(*CreateResponse) error
	Recv() (*CreateRequest, error)
	grpc.ServerStream
}

type Synchronization_FlushClient 

type Synchronization_FlushClient interface {
	Send(*FlushRequest) error
	Recv() (*FlushResponse, error)
	grpc.ClientStream
}

type Synchronization_FlushServer 

type Synchronization_FlushServer interface {
	Send(*FlushResponse) error
	Recv() (*FlushRequest, error)
	grpc.ServerStream
}

type Synchronization_PauseClient 

type Synchronization_PauseClient interface {
	Send(*PauseRequest) error
	Recv() (*PauseResponse, error)
	grpc.ClientStream
}

type Synchronization_PauseServer 

type Synchronization_PauseServer interface {
	Send(*PauseResponse) error
	Recv() (*PauseRequest, error)
	grpc.ServerStream
}

type Synchronization_ResetClient added in v0.10.2 

type Synchronization_ResetClient interface {
	Send(*ResetRequest) error
	Recv() (*ResetResponse, error)
	grpc.ClientStream
}

type Synchronization_ResetServer added in v0.10.2 

type Synchronization_ResetServer interface {
	Send(*ResetResponse) error
	Recv() (*ResetRequest, error)
	grpc.ServerStream
}

type Synchronization_ResumeClient 

type Synchronization_ResumeClient interface {
	Send(*ResumeRequest) error
	Recv() (*ResumeResponse, error)
	grpc.ClientStream
}

type Synchronization_ResumeServer 

type Synchronization_ResumeServer interface {
	Send(*ResumeResponse) error
	Recv() (*ResumeRequest, error)
	grpc.ServerStream
}

type Synchronization_TerminateClient 

type Synchronization_TerminateClient interface {
	Send(*TerminateRequest) error
	Recv() (*TerminateResponse, error)
	grpc.ClientStream
}

type Synchronization_TerminateServer 

type Synchronization_TerminateServer interface {
	Send(*TerminateResponse) error
	Recv() (*TerminateRequest, error)
	grpc.ServerStream
}

type TerminateRequest 

type TerminateRequest struct {
	Selection            *selection.Selection `protobuf:"bytes,1,opt,name=selection,proto3" json:"selection,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TerminateRequest) Descriptor 

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

func (*TerminateRequest) GetSelection 

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

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) Reset 

func (m *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (m *TerminateRequest) String() string

func (*TerminateRequest) XXX_DiscardUnknown 

func (m *TerminateRequest) XXX_DiscardUnknown()

func (*TerminateRequest) XXX_Marshal 

func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateRequest) XXX_Merge 

func (m *TerminateRequest) XXX_Merge(src proto.Message)

func (*TerminateRequest) XXX_Size 

func (m *TerminateRequest) XXX_Size() int

func (*TerminateRequest) XXX_Unmarshal 

func (m *TerminateRequest) XXX_Unmarshal(b []byte) error

type TerminateResponse 

type TerminateResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TerminateResponse) Descriptor 

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

func (*TerminateResponse) EnsureValid 

func (r *TerminateResponse) EnsureValid() error

EnsureValid verifies that a TerminateResponse is valid.

func (*TerminateResponse) GetMessage 

func (m *TerminateResponse) GetMessage() string

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) Reset 

func (m *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (m *TerminateResponse) String() string

func (*TerminateResponse) XXX_DiscardUnknown 

func (m *TerminateResponse) XXX_DiscardUnknown()

func (*TerminateResponse) XXX_Marshal 

func (m *TerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateResponse) XXX_Merge 

func (m *TerminateResponse) XXX_Merge(src proto.Message)

func (*TerminateResponse) XXX_Size 

func (m *TerminateResponse) XXX_Size() int

func (*TerminateResponse) XXX_Unmarshal 

func (m *TerminateResponse) XXX_Unmarshal(b []byte) error

type UnimplementedSynchronizationServer added in v0.10.1 

type UnimplementedSynchronizationServer struct {
}

UnimplementedSynchronizationServer can be embedded to have forward compatible implementations.

func (*UnimplementedSynchronizationServer) Create added in v0.10.1 

func (*UnimplementedSynchronizationServer) Create(srv Synchronization_CreateServer) error

func (*UnimplementedSynchronizationServer) Flush added in v0.10.1 

func (*UnimplementedSynchronizationServer) Flush(srv Synchronization_FlushServer) error

func (*UnimplementedSynchronizationServer) List added in v0.10.1 

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

func (*UnimplementedSynchronizationServer) Pause added in v0.10.1 

func (*UnimplementedSynchronizationServer) Pause(srv Synchronization_PauseServer) error

func (*UnimplementedSynchronizationServer) Reset added in v0.10.2 

func (*UnimplementedSynchronizationServer) Reset(srv Synchronization_ResetServer) error

func (*UnimplementedSynchronizationServer) Resume added in v0.10.1 

func (*UnimplementedSynchronizationServer) Resume(srv Synchronization_ResumeServer) error

func (*UnimplementedSynchronizationServer) Terminate added in v0.10.1 

func (*UnimplementedSynchronizationServer) Terminate(srv Synchronization_TerminateServer) error

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.