ecflowclient

package
v0.0.0-...-f734696 Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2019 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEcflowClientServiceServer 

func RegisterEcflowClientServiceServer(s *grpc.Server, srv EcflowClientServiceServer)

Types

type EcflowClientServiceClient 

type EcflowClientServiceClient interface {
	CollectStatusRecords(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusRecordsResponse, error)
	CollectStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	CollectNode(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeResponse, error)
}

EcflowClientServiceClient is the client API for EcflowClientService service.

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

func NewEcflowClientServiceClient 

func NewEcflowClientServiceClient(cc *grpc.ClientConn) EcflowClientServiceClient

type EcflowClientServiceServer 

type EcflowClientServiceServer interface {
	CollectStatusRecords(context.Context, *StatusRequest) (*StatusRecordsResponse, error)
	CollectStatus(context.Context, *StatusRequest) (*StatusResponse, error)
	CollectNode(context.Context, *NodeRequest) (*NodeResponse, error)
}

EcflowClientServiceServer is the server API for EcflowClientService service.

type NodeRequest 

type NodeRequest struct {
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Host                 string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Port                 string   `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	Path                 string   `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeRequest) Descriptor 

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

func (*NodeRequest) GetHost 

func (m *NodeRequest) GetHost() string

func (*NodeRequest) GetOwner 

func (m *NodeRequest) GetOwner() string

func (*NodeRequest) GetPath 

func (m *NodeRequest) GetPath() string

func (*NodeRequest) GetPort 

func (m *NodeRequest) GetPort() string

func (*NodeRequest) GetRepo 

func (m *NodeRequest) GetRepo() string

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

func (*NodeRequest) String 

func (m *NodeRequest) String() string

func (*NodeRequest) XXX_DiscardUnknown 

func (m *NodeRequest) XXX_DiscardUnknown()

func (*NodeRequest) XXX_Marshal 

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

func (*NodeRequest) XXX_Merge 

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

func (*NodeRequest) XXX_Size 

func (m *NodeRequest) XXX_Size() int

func (*NodeRequest) XXX_Unmarshal 

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

type NodeResponse 

type NodeResponse struct {
	Owner                string          `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string          `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Path                 string          `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Node                 string          `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	ResponseStatus       *ResponseStatus `protobuf:"bytes,5,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*NodeResponse) Descriptor 

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

func (*NodeResponse) GetNode 

func (m *NodeResponse) GetNode() string

func (*NodeResponse) GetOwner 

func (m *NodeResponse) GetOwner() string

func (*NodeResponse) GetPath 

func (m *NodeResponse) GetPath() string

func (*NodeResponse) GetRepo 

func (m *NodeResponse) GetRepo() string

func (*NodeResponse) GetResponseStatus 

func (m *NodeResponse) GetResponseStatus() *ResponseStatus

func (*NodeResponse) ProtoMessage 

func (*NodeResponse) ProtoMessage()

func (*NodeResponse) Reset 

func (m *NodeResponse) Reset()

func (*NodeResponse) String 

func (m *NodeResponse) String() string

func (*NodeResponse) XXX_DiscardUnknown 

func (m *NodeResponse) XXX_DiscardUnknown()

func (*NodeResponse) XXX_Marshal 

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

func (*NodeResponse) XXX_Merge 

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

func (*NodeResponse) XXX_Size 

func (m *NodeResponse) XXX_Size() int

func (*NodeResponse) XXX_Unmarshal 

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

type ResponseStatus 

type ResponseStatus struct {
	HasError             bool     `protobuf:"varint,1,opt,name=has_error,json=hasError,proto3" json:"has_error,omitempty"`
	ErrorString          string   `protobuf:"bytes,2,opt,name=error_string,json=errorString,proto3" json:"error_string,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseStatus) Descriptor 

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

func (*ResponseStatus) GetErrorString 

func (m *ResponseStatus) GetErrorString() string

func (*ResponseStatus) GetHasError 

func (m *ResponseStatus) GetHasError() bool

func (*ResponseStatus) ProtoMessage 

func (*ResponseStatus) ProtoMessage()

func (*ResponseStatus) Reset 

func (m *ResponseStatus) Reset()

func (*ResponseStatus) String 

func (m *ResponseStatus) String() string

func (*ResponseStatus) XXX_DiscardUnknown 

func (m *ResponseStatus) XXX_DiscardUnknown()

func (*ResponseStatus) XXX_Marshal 

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

func (*ResponseStatus) XXX_Merge 

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

func (*ResponseStatus) XXX_Size 

func (m *ResponseStatus) XXX_Size() int

func (*ResponseStatus) XXX_Unmarshal 

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

type StatusRecordsResponse 

type StatusRecordsResponse struct {
	Owner                string            `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string            `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	CollectedTimestamp   int64             `protobuf:"varint,3,opt,name=collected_timestamp,json=collectedTimestamp,proto3" json:"collected_timestamp,omitempty"`
	StatusMap            map[string]string `` /* 176-byte string literal not displayed */
	ResponseStatus       *ResponseStatus   `protobuf:"bytes,5,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StatusRecordsResponse) Descriptor 

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

func (*StatusRecordsResponse) GetCollectedTimestamp 

func (m *StatusRecordsResponse) GetCollectedTimestamp() int64

func (*StatusRecordsResponse) GetOwner 

func (m *StatusRecordsResponse) GetOwner() string

func (*StatusRecordsResponse) GetRepo 

func (m *StatusRecordsResponse) GetRepo() string

func (*StatusRecordsResponse) GetResponseStatus 

func (m *StatusRecordsResponse) GetResponseStatus() *ResponseStatus

func (*StatusRecordsResponse) GetStatusMap 

func (m *StatusRecordsResponse) GetStatusMap() map[string]string

func (*StatusRecordsResponse) ProtoMessage 

func (*StatusRecordsResponse) ProtoMessage()

func (*StatusRecordsResponse) Reset 

func (m *StatusRecordsResponse) Reset()

func (*StatusRecordsResponse) String 

func (m *StatusRecordsResponse) String() string

func (*StatusRecordsResponse) XXX_DiscardUnknown 

func (m *StatusRecordsResponse) XXX_DiscardUnknown()

func (*StatusRecordsResponse) XXX_Marshal 

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

func (*StatusRecordsResponse) XXX_Merge 

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

func (*StatusRecordsResponse) XXX_Size 

func (m *StatusRecordsResponse) XXX_Size() int

func (*StatusRecordsResponse) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	Owner                string   `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string   `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	Host                 string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Port                 string   `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) GetHost 

func (m *StatusRequest) GetHost() string

func (*StatusRequest) GetOwner 

func (m *StatusRequest) GetOwner() string

func (*StatusRequest) GetPort 

func (m *StatusRequest) GetPort() string

func (*StatusRequest) GetRepo 

func (m *StatusRequest) GetRepo() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	Owner                string          `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo                 string          `protobuf:"bytes,2,opt,name=repo,proto3" json:"repo,omitempty"`
	CollectedTimestamp   int64           `protobuf:"varint,3,opt,name=collected_timestamp,json=collectedTimestamp,proto3" json:"collected_timestamp,omitempty"`
	Status               string          `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	ResponseStatus       *ResponseStatus `protobuf:"bytes,5,opt,name=response_status,json=responseStatus,proto3" json:"response_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) GetCollectedTimestamp 

func (m *StatusResponse) GetCollectedTimestamp() int64

func (*StatusResponse) GetOwner 

func (m *StatusResponse) GetOwner() string

func (*StatusResponse) GetRepo 

func (m *StatusResponse) GetRepo() string

func (*StatusResponse) GetResponseStatus 

func (m *StatusResponse) GetResponseStatus() *ResponseStatus

func (*StatusResponse) GetStatus 

func (m *StatusResponse) GetStatus() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) String 

func (m *StatusResponse) String() string

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

func (m *StatusResponse) XXX_Unmarshal(b []byte) 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.