sync

Documentation

Overview

Package sync is a generated protocol buffer package.

It is generated from these files:

sync.proto

It has these top-level messages:

ResyncRequest
ResyncResponse

Package sync is a generated protocol buffer package.

It is generated from these files:

sync.proto

It has these top-level messages:

ResyncRequest
ResyncResponse

Index

• func RegisterSyncEndpointHandler(s server.Server, hdlr SyncEndpointHandler, opts ...server.HandlerOption)
• type ResyncRequest
  • func (*ResyncRequest) Descriptor() ([]byte, []int)
  • func (m *ResyncRequest) GetDryRun() bool
  • func (m *ResyncRequest) GetPath() string
  • func (m *ResyncRequest) GetTask() *jobs.Task
  • func (*ResyncRequest) ProtoMessage()
  • func (m *ResyncRequest) Reset()
  • func (m *ResyncRequest) String() string
• type ResyncResponse
  • func (*ResyncResponse) Descriptor() ([]byte, []int)
  • func (m *ResyncResponse) GetJsonDiff() string
  • func (m *ResyncResponse) GetSuccess() bool
  • func (m *ResyncResponse) GetTask() *jobs.Task
  • func (*ResyncResponse) ProtoMessage()
  • func (m *ResyncResponse) Reset()
  • func (m *ResyncResponse) String() string
• type SyncEndpoint
  • func (h *SyncEndpoint) TriggerResync(ctx context.Context, in *ResyncRequest, out *ResyncResponse) error
• type SyncEndpointClient
  • func NewSyncEndpointClient(serviceName string, c client.Client) SyncEndpointClient
• type SyncEndpointHandler

Functions

func RegisterSyncEndpointHandler

func RegisterSyncEndpointHandler(s server.Server, hdlr SyncEndpointHandler, opts ...server.HandlerOption)

Types

type ResyncRequest

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

func (*ResyncRequest) Descriptor

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

func (*ResyncRequest) GetDryRun

func (m *ResyncRequest) GetDryRun() bool

func (*ResyncRequest) GetPath

func (m *ResyncRequest) GetPath() string

func (*ResyncRequest) GetTask

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

func (*ResyncRequest) ProtoMessage

func (*ResyncRequest) ProtoMessage()

func (*ResyncRequest) Reset

func (m *ResyncRequest) Reset()

func (*ResyncRequest) String

func (m *ResyncRequest) String() string

type ResyncResponse

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

func (*ResyncResponse) Descriptor

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

func (*ResyncResponse) GetJsonDiff

func (m *ResyncResponse) GetJsonDiff() string

func (*ResyncResponse) GetSuccess

func (m *ResyncResponse) GetSuccess() bool

func (*ResyncResponse) GetTask

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

func (*ResyncResponse) ProtoMessage

func (*ResyncResponse) ProtoMessage()

func (*ResyncResponse) Reset

func (m *ResyncResponse) Reset()

func (*ResyncResponse) String

func (m *ResyncResponse) String() string

type SyncEndpoint

type SyncEndpoint struct {
	SyncEndpointHandler
}

func (*SyncEndpoint) TriggerResync

func (h *SyncEndpoint) TriggerResync(ctx context.Context, in *ResyncRequest, out *ResyncResponse) error

type SyncEndpointClient

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

func NewSyncEndpointClient

func NewSyncEndpointClient(serviceName string, c client.Client) SyncEndpointClient

type SyncEndpointHandler

type SyncEndpointHandler interface {
	TriggerResync(context.Context, *ResyncRequest, *ResyncResponse) error
}