pb

package
v0.0.1-alpha.6 Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2017 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

mcpserver.proto
processing.proto
workflow.proto

It has these top-level messages: 

ApproveTransferRequest
ApproveTransferResponse
ApproveJobRequest
ApproveJobResponse
ChoiceListRequest
ChoiceListResponse
Job
WorkflowGetRequest
WorkflowGetResponse
WorkflowData
WatchedDirectory
Chain
Link

Index

Constants

This section is empty.

Variables

View Source 
var ChoiceListResponse_Job_UnitType_name = map[int32]string{
	0: "UNKNOWN",
	1: "TRANSFER",
	2: "INGEST",
	3: "DIP",
}
View Source 
var ChoiceListResponse_Job_UnitType_value = map[string]int32{
	"UNKNOWN":  0,
	"TRANSFER": 1,
	"INGEST":   2,
	"DIP":      3,
}
View Source 
var Job_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "AWAITING_DECISION",
	2: "COMPLETED_SUCCESSFULLY",
	3: "EXECUTING_COMMANDS",
	4: "FAILED",
}
View Source 
var Job_Status_value = map[string]int32{
	"UNKNOWN":                0,
	"AWAITING_DECISION":      1,
	"COMPLETED_SUCCESSFULLY": 2,
	"EXECUTING_COMMANDS":     3,
	"FAILED":                 4,
}
View Source 
var WatchedDirectory_WatchedDirectoryType_name = map[int32]string{
	0: "UNKNOWN",
	1: "TRANSFER",
	2: "SIP",
	3: "DIP",
}
View Source 
var WatchedDirectory_WatchedDirectoryType_value = map[string]int32{
	"UNKNOWN":  0,
	"TRANSFER": 1,
	"SIP":      2,
	"DIP":      3,
}

Functions

func RegisterMCPServerServer 

func RegisterMCPServerServer(s *grpc.Server, srv MCPServerServer)

func RegisterWorkflowServer 

func RegisterWorkflowServer(s *grpc.Server, srv WorkflowServer)

Types

type ApproveJobRequest 

type ApproveJobRequest struct {
	Id       string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	ChoiceId string `protobuf:"bytes,2,opt,name=choiceId" json:"choiceId,omitempty"`
}

func (*ApproveJobRequest) Descriptor 

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

func (*ApproveJobRequest) GetChoiceId 

func (m *ApproveJobRequest) GetChoiceId() string

func (*ApproveJobRequest) GetId 

func (m *ApproveJobRequest) GetId() string

func (*ApproveJobRequest) ProtoMessage 

func (*ApproveJobRequest) ProtoMessage()

func (*ApproveJobRequest) Reset 

func (m *ApproveJobRequest) Reset()

func (*ApproveJobRequest) String 

func (m *ApproveJobRequest) String() string

type ApproveJobResponse 

type ApproveJobResponse struct {
	Approved bool `protobuf:"varint,1,opt,name=approved" json:"approved,omitempty"`
}

func (*ApproveJobResponse) Descriptor 

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

func (*ApproveJobResponse) GetApproved 

func (m *ApproveJobResponse) GetApproved() bool

func (*ApproveJobResponse) ProtoMessage 

func (*ApproveJobResponse) ProtoMessage()

func (*ApproveJobResponse) Reset 

func (m *ApproveJobResponse) Reset()

func (*ApproveJobResponse) String 

func (m *ApproveJobResponse) String() string

type ApproveTransferRequest 

type ApproveTransferRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*ApproveTransferRequest) Descriptor 

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

func (*ApproveTransferRequest) GetId 

func (m *ApproveTransferRequest) GetId() string

func (*ApproveTransferRequest) ProtoMessage 

func (*ApproveTransferRequest) ProtoMessage()

func (*ApproveTransferRequest) Reset 

func (m *ApproveTransferRequest) Reset()

func (*ApproveTransferRequest) String 

func (m *ApproveTransferRequest) String() string

type ApproveTransferResponse 

type ApproveTransferResponse struct {
	Approved bool `protobuf:"varint,1,opt,name=approved" json:"approved,omitempty"`
}

func (*ApproveTransferResponse) Descriptor 

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

func (*ApproveTransferResponse) GetApproved 

func (m *ApproveTransferResponse) GetApproved() bool

func (*ApproveTransferResponse) ProtoMessage 

func (*ApproveTransferResponse) ProtoMessage()

func (*ApproveTransferResponse) Reset 

func (m *ApproveTransferResponse) Reset()

func (*ApproveTransferResponse) String 

func (m *ApproveTransferResponse) String() string

type Chain 

type Chain struct {
	Description map[string]string `` /* 142-byte string literal not displayed */
	LinkId      string            `protobuf:"bytes,2,opt,name=linkId" json:"linkId,omitempty"`
	Id          string            `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
}

func (*Chain) Descriptor 

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

func (*Chain) GetDescription 

func (m *Chain) GetDescription() map[string]string

func (*Chain) GetId 

func (m *Chain) GetId() string

func (*Chain) GetLinkId 

func (m *Chain) GetLinkId() string

func (*Chain) ProtoMessage 

func (*Chain) ProtoMessage()

func (*Chain) Reset 

func (m *Chain) Reset()

func (*Chain) String 

func (m *Chain) String() string

type ChoiceListRequest 

type ChoiceListRequest struct {
}

func (*ChoiceListRequest) Descriptor 

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

func (*ChoiceListRequest) ProtoMessage 

func (*ChoiceListRequest) ProtoMessage()

func (*ChoiceListRequest) Reset 

func (m *ChoiceListRequest) Reset()

func (*ChoiceListRequest) String 

func (m *ChoiceListRequest) String() string

type ChoiceListResponse 

type ChoiceListResponse struct {
	Jobs          []*ChoiceListResponse_Job `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"`
	TransferCount int32                     `protobuf:"varint,2,opt,name=transferCount" json:"transferCount,omitempty"`
	IngestCount   int32                     `protobuf:"varint,3,opt,name=ingestCount" json:"ingestCount,omitempty"`
}

func (*ChoiceListResponse) Descriptor 

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

func (*ChoiceListResponse) GetIngestCount 

func (m *ChoiceListResponse) GetIngestCount() int32

func (*ChoiceListResponse) GetJobs 

func (m *ChoiceListResponse) GetJobs() []*ChoiceListResponse_Job

func (*ChoiceListResponse) GetTransferCount 

func (m *ChoiceListResponse) GetTransferCount() int32

func (*ChoiceListResponse) ProtoMessage 

func (*ChoiceListResponse) ProtoMessage()

func (*ChoiceListResponse) Reset 

func (m *ChoiceListResponse) Reset()

func (*ChoiceListResponse) String 

func (m *ChoiceListResponse) String() string

type ChoiceListResponse_Job 

type ChoiceListResponse_Job struct {
	Id       string                           `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	UnitType ChoiceListResponse_Job_UnitType  `protobuf:"varint,2,opt,name=unitType,enum=pb.ChoiceListResponse_Job_UnitType" json:"unitType,omitempty"`
	Choices  []*ChoiceListResponse_Job_Choice `protobuf:"bytes,3,rep,name=choices" json:"choices,omitempty"`
}

func (*ChoiceListResponse_Job) Descriptor 

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

func (*ChoiceListResponse_Job) GetChoices 

func (m *ChoiceListResponse_Job) GetChoices() []*ChoiceListResponse_Job_Choice

func (*ChoiceListResponse_Job) GetId 

func (m *ChoiceListResponse_Job) GetId() string

func (*ChoiceListResponse_Job) GetUnitType 

func (m *ChoiceListResponse_Job) GetUnitType() ChoiceListResponse_Job_UnitType

func (*ChoiceListResponse_Job) ProtoMessage 

func (*ChoiceListResponse_Job) ProtoMessage()

func (*ChoiceListResponse_Job) Reset 

func (m *ChoiceListResponse_Job) Reset()

func (*ChoiceListResponse_Job) String 

func (m *ChoiceListResponse_Job) String() string

type ChoiceListResponse_Job_Choice 

type ChoiceListResponse_Job_Choice struct {
	Value       string `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
}

func (*ChoiceListResponse_Job_Choice) Descriptor 

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

func (*ChoiceListResponse_Job_Choice) GetDescription 

func (m *ChoiceListResponse_Job_Choice) GetDescription() string

func (*ChoiceListResponse_Job_Choice) GetValue 

func (m *ChoiceListResponse_Job_Choice) GetValue() string

func (*ChoiceListResponse_Job_Choice) ProtoMessage 

func (*ChoiceListResponse_Job_Choice) ProtoMessage()

func (*ChoiceListResponse_Job_Choice) Reset 

func (m *ChoiceListResponse_Job_Choice) Reset()

func (*ChoiceListResponse_Job_Choice) String 

func (m *ChoiceListResponse_Job_Choice) String() string

type ChoiceListResponse_Job_UnitType 

type ChoiceListResponse_Job_UnitType int32
const (
	ChoiceListResponse_Job_UNKNOWN  ChoiceListResponse_Job_UnitType = 0
	ChoiceListResponse_Job_TRANSFER ChoiceListResponse_Job_UnitType = 1
	ChoiceListResponse_Job_INGEST   ChoiceListResponse_Job_UnitType = 2
	ChoiceListResponse_Job_DIP      ChoiceListResponse_Job_UnitType = 3
)

func (ChoiceListResponse_Job_UnitType) EnumDescriptor 

func (ChoiceListResponse_Job_UnitType) EnumDescriptor() ([]byte, []int)

func (ChoiceListResponse_Job_UnitType) String 

func (x ChoiceListResponse_Job_UnitType) String() string

type Job 

type Job struct {
	Status Job_Status `protobuf:"varint,1,opt,name=status,enum=pb.Job_Status" json:"status,omitempty"`
}

func (*Job) Descriptor 

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

func (*Job) GetStatus 

func (m *Job) GetStatus() Job_Status

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

type Job_Status 

type Job_Status int32
const (
	Job_UNKNOWN                Job_Status = 0
	Job_AWAITING_DECISION      Job_Status = 1
	Job_COMPLETED_SUCCESSFULLY Job_Status = 2
	Job_EXECUTING_COMMANDS     Job_Status = 3
	Job_FAILED                 Job_Status = 4
)

func (Job_Status) EnumDescriptor 

func (Job_Status) EnumDescriptor() ([]byte, []int)

func (Job_Status) String 

func (x Job_Status) String() string
type Link struct {
	Description       map[string]string    `` /* 142-byte string literal not displayed */
	Group             map[string]string    `` /* 130-byte string literal not displayed */
	FallbackJobStatus Job_Status           `protobuf:"varint,3,opt,name=fallbackJobStatus,enum=pb.Job_Status" json:"fallbackJobStatus,omitempty"`
	FallbackLinkId    string               `protobuf:"bytes,4,opt,name=fallbackLinkId" json:"fallbackLinkId,omitempty"`
	ExitCodes         []*Link_LinkExitCode `protobuf:"bytes,5,rep,name=exitCodes" json:"exitCodes,omitempty"`
	Config            *Link_LinkConfig     `protobuf:"bytes,6,opt,name=config" json:"config,omitempty"`
	Id                string               `protobuf:"bytes,7,opt,name=id" json:"id,omitempty"`
}

func (*Link) Descriptor 

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

func (*Link) GetConfig 

func (m *Link) GetConfig() *Link_LinkConfig

func (*Link) GetDescription 

func (m *Link) GetDescription() map[string]string

func (*Link) GetExitCodes 

func (m *Link) GetExitCodes() []*Link_LinkExitCode

func (*Link) GetFallbackJobStatus 

func (m *Link) GetFallbackJobStatus() Job_Status

func (*Link) GetFallbackLinkId 

func (m *Link) GetFallbackLinkId() string

func (*Link) GetGroup 

func (m *Link) GetGroup() map[string]string

func (*Link) GetId 

func (m *Link) GetId() string

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) Reset 

func (m *Link) Reset()

func (*Link) String 

func (m *Link) String() string
type Link_LinkConfig struct {
	Manager string `protobuf:"bytes,1,opt,name=manager" json:"manager,omitempty"`
	Model   string `protobuf:"bytes,2,opt,name=model" json:"model,omitempty"`
	// Types that are valid to be assigned to Attrs:
	//	*Link_LinkConfig_Standard_
	//	*Link_LinkConfig_UserChoice_
	//	*Link_LinkConfig_UserChoiceDict_
	//	*Link_LinkConfig_SetUnitVar_
	//	*Link_LinkConfig_GetUnitVar_
	//	*Link_LinkConfig_Magic_
	Attrs isLink_LinkConfig_Attrs `protobuf_oneof:"attrs"`
}
func (*Link_LinkConfig) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig) GetAttrs() isLink_LinkConfig_Attrs
func (m *Link_LinkConfig) GetGetUnitVar() *Link_LinkConfig_GetUnitVar
func (m *Link_LinkConfig) GetMagic() *Link_LinkConfig_Magic
func (m *Link_LinkConfig) GetManager() string
func (m *Link_LinkConfig) GetModel() string
func (m *Link_LinkConfig) GetSetUnitVar() *Link_LinkConfig_SetUnitVar
func (m *Link_LinkConfig) GetStandard() *Link_LinkConfig_Standard
func (m *Link_LinkConfig) GetUserChoice() *Link_LinkConfig_UserChoice
func (m *Link_LinkConfig) GetUserChoiceDict() *Link_LinkConfig_UserChoiceDict
func (*Link_LinkConfig) ProtoMessage()
func (m *Link_LinkConfig) Reset()
func (m *Link_LinkConfig) String() string
func (*Link_LinkConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package. 

type Link_LinkConfig_GetUnitVar struct {
	Variable string `protobuf:"bytes,1,opt,name=variable" json:"variable,omitempty"`
	LinkId   string `protobuf:"bytes,2,opt,name=linkId" json:"linkId,omitempty"`
}
func (*Link_LinkConfig_GetUnitVar) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_GetUnitVar) GetLinkId() string
func (m *Link_LinkConfig_GetUnitVar) GetVariable() string
func (*Link_LinkConfig_GetUnitVar) ProtoMessage()
func (m *Link_LinkConfig_GetUnitVar) Reset()
func (m *Link_LinkConfig_GetUnitVar) String() string

type Link_LinkConfig_GetUnitVar_ 

type Link_LinkConfig_GetUnitVar_ struct {
	GetUnitVar *Link_LinkConfig_GetUnitVar `protobuf:"bytes,7,opt,name=getUnitVar,oneof"`
}
type Link_LinkConfig_Magic struct {
	LinkId string `protobuf:"bytes,1,opt,name=linkId" json:"linkId,omitempty"`
}
func (*Link_LinkConfig_Magic) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_Magic) GetLinkId() string
func (*Link_LinkConfig_Magic) ProtoMessage()
func (m *Link_LinkConfig_Magic) Reset()
func (m *Link_LinkConfig_Magic) String() string

type Link_LinkConfig_Magic_ 

type Link_LinkConfig_Magic_ struct {
	Magic *Link_LinkConfig_Magic `protobuf:"bytes,8,opt,name=magic,oneof"`
}
type Link_LinkConfig_SetUnitVar struct {
	Variable      string `protobuf:"bytes,1,opt,name=variable" json:"variable,omitempty"`
	VariableValue string `protobuf:"bytes,2,opt,name=variableValue" json:"variableValue,omitempty"`
	LinkId        string `protobuf:"bytes,3,opt,name=linkId" json:"linkId,omitempty"`
}
func (*Link_LinkConfig_SetUnitVar) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_SetUnitVar) GetLinkId() string
func (m *Link_LinkConfig_SetUnitVar) GetVariable() string
func (m *Link_LinkConfig_SetUnitVar) GetVariableValue() string
func (*Link_LinkConfig_SetUnitVar) ProtoMessage()
func (m *Link_LinkConfig_SetUnitVar) Reset()
func (m *Link_LinkConfig_SetUnitVar) String() string

type Link_LinkConfig_SetUnitVar_ 

type Link_LinkConfig_SetUnitVar_ struct {
	SetUnitVar *Link_LinkConfig_SetUnitVar `protobuf:"bytes,6,opt,name=setUnitVar,oneof"`
}
type Link_LinkConfig_Standard struct {
	Execute            string `protobuf:"bytes,1,opt,name=execute" json:"execute,omitempty"`
	Arguments          string `protobuf:"bytes,2,opt,name=arguments" json:"arguments,omitempty"`
	FilterSubdir       string `protobuf:"bytes,3,opt,name=filterSubdir" json:"filterSubdir,omitempty"`
	FilterFileEnd      string `protobuf:"bytes,4,opt,name=filterFileEnd" json:"filterFileEnd,omitempty"`
	StdoutFile         string `protobuf:"bytes,5,opt,name=stdoutFile" json:"stdoutFile,omitempty"`
	StderrFile         string `protobuf:"bytes,6,opt,name=stderrFile" json:"stderrFile,omitempty"`
	RequiresOutputLock bool   `protobuf:"varint,7,opt,name=requiresOutputLock" json:"requiresOutputLock,omitempty"`
}
func (*Link_LinkConfig_Standard) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_Standard) GetArguments() string
func (m *Link_LinkConfig_Standard) GetExecute() string
func (m *Link_LinkConfig_Standard) GetFilterFileEnd() string
func (m *Link_LinkConfig_Standard) GetFilterSubdir() string
func (m *Link_LinkConfig_Standard) GetRequiresOutputLock() bool
func (m *Link_LinkConfig_Standard) GetStderrFile() string
func (m *Link_LinkConfig_Standard) GetStdoutFile() string
func (*Link_LinkConfig_Standard) ProtoMessage()
func (m *Link_LinkConfig_Standard) Reset()
func (m *Link_LinkConfig_Standard) String() string

type Link_LinkConfig_Standard_ 

type Link_LinkConfig_Standard_ struct {
	Standard *Link_LinkConfig_Standard `protobuf:"bytes,3,opt,name=standard,oneof"`
}
type Link_LinkConfig_UserChoice struct {
	ChainIds []string `protobuf:"bytes,1,rep,name=chainIds" json:"chainIds,omitempty"`
}
func (*Link_LinkConfig_UserChoice) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_UserChoice) GetChainIds() []string
func (*Link_LinkConfig_UserChoice) ProtoMessage()
func (m *Link_LinkConfig_UserChoice) Reset()
func (m *Link_LinkConfig_UserChoice) String() string
type Link_LinkConfig_UserChoiceDict struct {
	Replacements []*Link_LinkConfig_UserChoiceDict_Replacement `protobuf:"bytes,1,rep,name=replacements" json:"replacements,omitempty"`
}
func (*Link_LinkConfig_UserChoiceDict) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_UserChoiceDict) GetReplacements() []*Link_LinkConfig_UserChoiceDict_Replacement
func (*Link_LinkConfig_UserChoiceDict) ProtoMessage()
func (m *Link_LinkConfig_UserChoiceDict) Reset()
func (m *Link_LinkConfig_UserChoiceDict) String() string

type Link_LinkConfig_UserChoiceDict_ 

type Link_LinkConfig_UserChoiceDict_ struct {
	UserChoiceDict *Link_LinkConfig_UserChoiceDict `protobuf:"bytes,5,opt,name=userChoiceDict,oneof"`
}
type Link_LinkConfig_UserChoiceDict_Replacement struct {
	Id          string            `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Description map[string]string `` /* 142-byte string literal not displayed */
	Items       map[string]string `` /* 130-byte string literal not displayed */
}
func (*Link_LinkConfig_UserChoiceDict_Replacement) Descriptor() ([]byte, []int)
func (m *Link_LinkConfig_UserChoiceDict_Replacement) GetDescription() map[string]string
func (m *Link_LinkConfig_UserChoiceDict_Replacement) GetId() string
func (m *Link_LinkConfig_UserChoiceDict_Replacement) GetItems() map[string]string
func (*Link_LinkConfig_UserChoiceDict_Replacement) ProtoMessage()
func (m *Link_LinkConfig_UserChoiceDict_Replacement) Reset()
func (m *Link_LinkConfig_UserChoiceDict_Replacement) String() string

type Link_LinkConfig_UserChoice_ 

type Link_LinkConfig_UserChoice_ struct {
	UserChoice *Link_LinkConfig_UserChoice `protobuf:"bytes,4,opt,name=userChoice,oneof"`
}
type Link_LinkExitCode struct {
	Code      uint32     `protobuf:"varint,1,opt,name=code" json:"code,omitempty"`
	JobStatus Job_Status `protobuf:"varint,2,opt,name=jobStatus,enum=pb.Job_Status" json:"jobStatus,omitempty"`
	LinkId    string     `protobuf:"bytes,3,opt,name=linkId" json:"linkId,omitempty"`
}
func (*Link_LinkExitCode) Descriptor() ([]byte, []int)
func (m *Link_LinkExitCode) GetCode() uint32
func (m *Link_LinkExitCode) GetJobStatus() Job_Status
func (m *Link_LinkExitCode) GetLinkId() string
func (*Link_LinkExitCode) ProtoMessage()
func (m *Link_LinkExitCode) Reset()
func (m *Link_LinkExitCode) String() string

type MCPServerClient 

type MCPServerClient interface {
	// ApproveJob proceeds processing with a choice given by the user
	ApproveJob(ctx context.Context, in *ApproveJobRequest, opts ...grpc.CallOption) (*ApproveJobResponse, error)
	// ApproveTransfer starts a transfer awaiting for approval
	ApproveTransfer(ctx context.Context, in *ApproveTransferRequest, opts ...grpc.CallOption) (*ApproveTransferResponse, error)
	// ChoiceList returns the list of job choices awaiting for decision
	ChoiceList(ctx context.Context, in *ChoiceListRequest, opts ...grpc.CallOption) (*ChoiceListResponse, error)
}

func NewMCPServerClient 

func NewMCPServerClient(cc *grpc.ClientConn) MCPServerClient

type MCPServerServer 

type MCPServerServer interface {
	// ApproveJob proceeds processing with a choice given by the user
	ApproveJob(context.Context, *ApproveJobRequest) (*ApproveJobResponse, error)
	// ApproveTransfer starts a transfer awaiting for approval
	ApproveTransfer(context.Context, *ApproveTransferRequest) (*ApproveTransferResponse, error)
	// ChoiceList returns the list of job choices awaiting for decision
	ChoiceList(context.Context, *ChoiceListRequest) (*ChoiceListResponse, error)
}

type WatchedDirectory 

type WatchedDirectory struct {
	Type     WatchedDirectory_WatchedDirectoryType `protobuf:"varint,1,opt,name=type,enum=pb.WatchedDirectory_WatchedDirectoryType" json:"type,omitempty"`
	Path     string                                `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
	OnlyDirs bool                                  `protobuf:"varint,3,opt,name=onlyDirs" json:"onlyDirs,omitempty"`
	ChainId  string                                `protobuf:"bytes,4,opt,name=chainId" json:"chainId,omitempty"`
}

func (*WatchedDirectory) Descriptor 

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

func (*WatchedDirectory) GetChainId 

func (m *WatchedDirectory) GetChainId() string

func (*WatchedDirectory) GetOnlyDirs 

func (m *WatchedDirectory) GetOnlyDirs() bool

func (*WatchedDirectory) GetPath 

func (m *WatchedDirectory) GetPath() string

func (*WatchedDirectory) GetType 

func (m *WatchedDirectory) GetType() WatchedDirectory_WatchedDirectoryType

func (*WatchedDirectory) ProtoMessage 

func (*WatchedDirectory) ProtoMessage()

func (*WatchedDirectory) Reset 

func (m *WatchedDirectory) Reset()

func (*WatchedDirectory) String 

func (m *WatchedDirectory) String() string

type WatchedDirectory_WatchedDirectoryType 

type WatchedDirectory_WatchedDirectoryType int32
const (
	WatchedDirectory_UNKNOWN  WatchedDirectory_WatchedDirectoryType = 0
	WatchedDirectory_TRANSFER WatchedDirectory_WatchedDirectoryType = 1
	WatchedDirectory_SIP      WatchedDirectory_WatchedDirectoryType = 2
	WatchedDirectory_DIP      WatchedDirectory_WatchedDirectoryType = 3
)

func (WatchedDirectory_WatchedDirectoryType) EnumDescriptor 

func (WatchedDirectory_WatchedDirectoryType) EnumDescriptor() ([]byte, []int)

func (WatchedDirectory_WatchedDirectoryType) String 

func (x WatchedDirectory_WatchedDirectoryType) String() string

type WorkflowClient 

type WorkflowClient interface {
	WorkflowGet(ctx context.Context, in *WorkflowGetRequest, opts ...grpc.CallOption) (*WorkflowGetResponse, error)
}

func NewWorkflowClient 

func NewWorkflowClient(cc *grpc.ClientConn) WorkflowClient

type WorkflowData 

type WorkflowData struct {
	WatchedDirectories []*WatchedDirectory `protobuf:"bytes,1,rep,name=watchedDirectories" json:"watchedDirectories,omitempty"`
	Chains             map[string]*Chain   `` /* 132-byte string literal not displayed */
	Links              map[string]*Link    `` /* 130-byte string literal not displayed */
}

func (*WorkflowData) Descriptor 

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

func (*WorkflowData) GetChains 

func (m *WorkflowData) GetChains() map[string]*Chain
func (m *WorkflowData) GetLinks() map[string]*Link

func (*WorkflowData) GetWatchedDirectories 

func (m *WorkflowData) GetWatchedDirectories() []*WatchedDirectory

func (*WorkflowData) MarshalJSON 

func (w *WorkflowData) MarshalJSON() ([]byte, error)

MarshalJSON implements Marshaler. This methos returns the current WorkflowData message encoded as JSON.

func (*WorkflowData) ProtoMessage 

func (*WorkflowData) ProtoMessage()

func (*WorkflowData) Reset 

func (m *WorkflowData) Reset()

func (*WorkflowData) String 

func (m *WorkflowData) String() string

func (*WorkflowData) UnmarshalJSON 

func (w *WorkflowData) UnmarshalJSON(data []byte) error

UnmarshalJSON implements Unmarshaler. This method updates the current WorkflowData message with the information found in the JSON blob.

type WorkflowGetRequest 

type WorkflowGetRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*WorkflowGetRequest) Descriptor 

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

func (*WorkflowGetRequest) GetId 

func (m *WorkflowGetRequest) GetId() string

func (*WorkflowGetRequest) ProtoMessage 

func (*WorkflowGetRequest) ProtoMessage()

func (*WorkflowGetRequest) Reset 

func (m *WorkflowGetRequest) Reset()

func (*WorkflowGetRequest) String 

func (m *WorkflowGetRequest) String() string

type WorkflowGetResponse 

type WorkflowGetResponse struct {
	Workflow *WorkflowData `protobuf:"bytes,1,opt,name=workflow" json:"workflow,omitempty"`
	Error    string        `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*WorkflowGetResponse) Descriptor 

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

func (*WorkflowGetResponse) GetError 

func (m *WorkflowGetResponse) GetError() string

func (*WorkflowGetResponse) GetWorkflow 

func (m *WorkflowGetResponse) GetWorkflow() *WorkflowData

func (*WorkflowGetResponse) ProtoMessage 

func (*WorkflowGetResponse) ProtoMessage()

func (*WorkflowGetResponse) Reset 

func (m *WorkflowGetResponse) Reset()

func (*WorkflowGetResponse) String 

func (m *WorkflowGetResponse) String() string

type WorkflowServer 

type WorkflowServer interface {
	WorkflowGet(context.Context, *WorkflowGetRequest) (*WorkflowGetResponse, 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.