replicant

type AttachmentForType struct {

	// The attachment name, e.g. "image".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The document type, e.g. "core/image".
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type ChangeTargetStateRequest struct {

	// Name of the replication target.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The action to perform on the target.
	Action TargetAction `protobuf:"varint,2,opt,name=action,proto3,enum=elephant.replicant.TargetAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

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

type ConfigureTargetRequest struct {

	// Name is the identifier for the replication target.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The URL of the target repository to replicate to.
	RepositoryUrl string `protobuf:"bytes,2,opt,name=repository_url,json=repositoryUrl,proto3" json:"repository_url,omitempty"`
	// The OIDC discovery configuration URL for target authentication.
	OidcConfig string `protobuf:"bytes,3,opt,name=oidc_config,json=oidcConfig,proto3" json:"oidc_config,omitempty"`
	// The OAuth2 client ID for target authentication.
	ClientId string `protobuf:"bytes,4,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// The OAuth2 client secret for target authentication.
	ClientSecret string `protobuf:"bytes,5,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	// The event log position to start replication from.
	StartFrom int64 `protobuf:"varint,6,opt,name=start_from,json=startFrom,proto3" json:"start_from,omitempty"`
	// Sync configuration controlling what gets replicated.
	Config *SyncConfig `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTargetStateRequest struct {

	// Name of the replication target.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetTargetStateResponse struct {

	// The current state of the replication target.
	State TargetState `protobuf:"varint,1,opt,name=state,proto3,enum=elephant.replicant.TargetState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type RemoveTargetRequest struct {

	// Name of the replication target to remove.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

type Replication interface {
	// SendDocument triggers replication of a single document by UUID.
	SendDocument(context.Context, *SendDocumentRequest) (*SendDocumentResponse, error)

	// ConfigureTarget creates or updates a replication target. The configuration
	// maps to the environment variables used for static configuration in
	// elephant-replicant.
	ConfigureTarget(context.Context, *ConfigureTargetRequest) (*ConfigureTargetResponse, error)

	// RemoveTarget deletes a replication target and stops its replication.
	RemoveTarget(context.Context, *RemoveTargetRequest) (*RemoveTargetResponse, error)

	// ChangeTargetState starts or stops a replication target.
	ChangeTargetState(context.Context, *ChangeTargetStateRequest) (*ChangeTargetStateResponse, error)

	// GetTargetState returns the current state of a replication target.
	GetTargetState(context.Context, *GetTargetStateRequest) (*GetTargetStateResponse, error)
}

type SectionForType struct {

	// The document type, e.g. "core/event".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// The UUID of the section to ignore.
	SectionUuid string `protobuf:"bytes,2,opt,name=section_uuid,json=sectionUuid,proto3" json:"section_uuid,omitempty"`
	// contains filtered or unexported fields
}

type SendDocumentRequest struct {

	// The UUID of the document to replicate.
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// Force replication even if the document has already been replicated.
	Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"`
	// contains filtered or unexported fields
}

type SendDocumentResponse struct {

	// The version of the document that was replicated to the target.
	TargetVersion int64 `protobuf:"varint,1,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// contains filtered or unexported fields
}

type SyncConfig struct {

	// Accept and skip documents that fail to replicate instead of blocking.
	AcceptErrors bool `protobuf:"varint,1,opt,name=accept_errors,json=acceptErrors,proto3" json:"accept_errors,omitempty"`
	// Replicate all attachments for documents.
	AllAttachments bool `protobuf:"varint,2,opt,name=all_attachments,json=allAttachments,proto3" json:"all_attachments,omitempty"`
	// Document types to exclude from replication.
	IgnoreTypes []string `protobuf:"bytes,3,rep,name=ignore_types,json=ignoreTypes,proto3" json:"ignore_types,omitempty"`
	// Sections to exclude from replication, identified by document type and
	// section UUID.
	IgnoreSections []*SectionForType `protobuf:"bytes,4,rep,name=ignore_sections,json=ignoreSections,proto3" json:"ignore_sections,omitempty"`
	// Specific attachments to include when all_attachments is false.
	IncludeAttachments []*AttachmentForType `protobuf:"bytes,5,rep,name=include_attachments,json=includeAttachments,proto3" json:"include_attachments,omitempty"`
	// Ignore events generated by these client subs.
	IgnoreSubs []string `protobuf:"bytes,6,rep,name=ignore_subs,json=ignoreSubs,proto3" json:"ignore_subs,omitempty"`
	// contains filtered or unexported fields
}

type TargetAction int32

type TargetState int32

type TwirpServer interface {
	http.Handler

	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// google.golang.org/protobuf/types/descriptorpb.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)

	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string

	// PathPrefix returns the HTTP URL path prefix for all methods handled by this
	// service. This can be used with an HTTP mux to route Twirp requests.
	// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
	// that is, everything in a Twirp route except for the <Method> at the end.
	PathPrefix() string
}