operatorservice

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Jun 1, 2022 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterOperatorServiceServer 

func RegisterOperatorServiceServer(s *grpc.Server, srv OperatorServiceServer)

Types

type AddSearchAttributesRequest 

type AddSearchAttributesRequest struct {
	// Mapping between search attribute name and its IndexedValueType.
	SearchAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
}

func (*AddSearchAttributesRequest) Descriptor 

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

func (*AddSearchAttributesRequest) Equal 

func (this *AddSearchAttributesRequest) Equal(that interface{}) bool

func (*AddSearchAttributesRequest) GetSearchAttributes 

func (m *AddSearchAttributesRequest) GetSearchAttributes() map[string]v1.IndexedValueType

func (*AddSearchAttributesRequest) GoString 

func (this *AddSearchAttributesRequest) GoString() string

func (*AddSearchAttributesRequest) Marshal 

func (m *AddSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*AddSearchAttributesRequest) MarshalTo 

func (m *AddSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddSearchAttributesRequest) MarshalToSizedBuffer 

func (m *AddSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddSearchAttributesRequest) ProtoMessage 

func (*AddSearchAttributesRequest) ProtoMessage()

func (*AddSearchAttributesRequest) Reset 

func (m *AddSearchAttributesRequest) Reset()

func (*AddSearchAttributesRequest) Size 

func (m *AddSearchAttributesRequest) Size() (n int)

func (*AddSearchAttributesRequest) String 

func (this *AddSearchAttributesRequest) String() string

func (*AddSearchAttributesRequest) Unmarshal 

func (m *AddSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*AddSearchAttributesRequest) XXX_DiscardUnknown 

func (m *AddSearchAttributesRequest) XXX_DiscardUnknown()

func (*AddSearchAttributesRequest) XXX_Marshal 

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

func (*AddSearchAttributesRequest) XXX_Merge 

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

func (*AddSearchAttributesRequest) XXX_Size 

func (m *AddSearchAttributesRequest) XXX_Size() int

func (*AddSearchAttributesRequest) XXX_Unmarshal 

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

type AddSearchAttributesResponse 

type AddSearchAttributesResponse struct {
}

func (*AddSearchAttributesResponse) Descriptor 

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

func (*AddSearchAttributesResponse) Equal 

func (this *AddSearchAttributesResponse) Equal(that interface{}) bool

func (*AddSearchAttributesResponse) GoString 

func (this *AddSearchAttributesResponse) GoString() string

func (*AddSearchAttributesResponse) Marshal 

func (m *AddSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*AddSearchAttributesResponse) MarshalTo 

func (m *AddSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddSearchAttributesResponse) MarshalToSizedBuffer 

func (m *AddSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddSearchAttributesResponse) ProtoMessage 

func (*AddSearchAttributesResponse) ProtoMessage()

func (*AddSearchAttributesResponse) Reset 

func (m *AddSearchAttributesResponse) Reset()

func (*AddSearchAttributesResponse) Size 

func (m *AddSearchAttributesResponse) Size() (n int)

func (*AddSearchAttributesResponse) String 

func (this *AddSearchAttributesResponse) String() string

func (*AddSearchAttributesResponse) Unmarshal 

func (m *AddSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*AddSearchAttributesResponse) XXX_DiscardUnknown 

func (m *AddSearchAttributesResponse) XXX_DiscardUnknown()

func (*AddSearchAttributesResponse) XXX_Marshal 

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

func (*AddSearchAttributesResponse) XXX_Merge 

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

func (*AddSearchAttributesResponse) XXX_Size 

func (m *AddSearchAttributesResponse) XXX_Size() int

func (*AddSearchAttributesResponse) XXX_Unmarshal 

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

type ListSearchAttributesRequest 

type ListSearchAttributesRequest struct {
}

func (*ListSearchAttributesRequest) Descriptor 

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

func (*ListSearchAttributesRequest) Equal 

func (this *ListSearchAttributesRequest) Equal(that interface{}) bool

func (*ListSearchAttributesRequest) GoString 

func (this *ListSearchAttributesRequest) GoString() string

func (*ListSearchAttributesRequest) Marshal 

func (m *ListSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*ListSearchAttributesRequest) MarshalTo 

func (m *ListSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListSearchAttributesRequest) MarshalToSizedBuffer 

func (m *ListSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSearchAttributesRequest) ProtoMessage 

func (*ListSearchAttributesRequest) ProtoMessage()

func (*ListSearchAttributesRequest) Reset 

func (m *ListSearchAttributesRequest) Reset()

func (*ListSearchAttributesRequest) Size 

func (m *ListSearchAttributesRequest) Size() (n int)

func (*ListSearchAttributesRequest) String 

func (this *ListSearchAttributesRequest) String() string

func (*ListSearchAttributesRequest) Unmarshal 

func (m *ListSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*ListSearchAttributesRequest) XXX_DiscardUnknown 

func (m *ListSearchAttributesRequest) XXX_DiscardUnknown()

func (*ListSearchAttributesRequest) XXX_Marshal 

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

func (*ListSearchAttributesRequest) XXX_Merge 

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

func (*ListSearchAttributesRequest) XXX_Size 

func (m *ListSearchAttributesRequest) XXX_Size() int

func (*ListSearchAttributesRequest) XXX_Unmarshal 

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

type ListSearchAttributesResponse 

type ListSearchAttributesResponse struct {
	// Mapping between custom (user-registered) search attribute name to its IndexedValueType.
	CustomAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping between system (predefined) search attribute name to its IndexedValueType.
	SystemAttributes map[string]v1.IndexedValueType `` /* 242-byte string literal not displayed */
	// Mapping from the attribute name to the visibility storage native type
	StorageSchema map[string]string `` /* 188-byte string literal not displayed */
}

func (*ListSearchAttributesResponse) Descriptor 

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

func (*ListSearchAttributesResponse) Equal 

func (this *ListSearchAttributesResponse) Equal(that interface{}) bool

func (*ListSearchAttributesResponse) GetCustomAttributes 

func (m *ListSearchAttributesResponse) GetCustomAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GetStorageSchema 

func (m *ListSearchAttributesResponse) GetStorageSchema() map[string]string

func (*ListSearchAttributesResponse) GetSystemAttributes 

func (m *ListSearchAttributesResponse) GetSystemAttributes() map[string]v1.IndexedValueType

func (*ListSearchAttributesResponse) GoString 

func (this *ListSearchAttributesResponse) GoString() string

func (*ListSearchAttributesResponse) Marshal 

func (m *ListSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*ListSearchAttributesResponse) MarshalTo 

func (m *ListSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListSearchAttributesResponse) MarshalToSizedBuffer 

func (m *ListSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListSearchAttributesResponse) ProtoMessage 

func (*ListSearchAttributesResponse) ProtoMessage()

func (*ListSearchAttributesResponse) Reset 

func (m *ListSearchAttributesResponse) Reset()

func (*ListSearchAttributesResponse) Size 

func (m *ListSearchAttributesResponse) Size() (n int)

func (*ListSearchAttributesResponse) String 

func (this *ListSearchAttributesResponse) String() string

func (*ListSearchAttributesResponse) Unmarshal 

func (m *ListSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*ListSearchAttributesResponse) XXX_DiscardUnknown 

func (m *ListSearchAttributesResponse) XXX_DiscardUnknown()

func (*ListSearchAttributesResponse) XXX_Marshal 

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

func (*ListSearchAttributesResponse) XXX_Merge 

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

func (*ListSearchAttributesResponse) XXX_Size 

func (m *ListSearchAttributesResponse) XXX_Size() int

func (*ListSearchAttributesResponse) XXX_Unmarshal 

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

type OperatorServiceClient 

type OperatorServiceClient interface {
	// AddSearchAttributes add custom search attributes.
	//
	// If successful, returns AddSearchAttributesResponse.
	// If fails, returns INTERNAL code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details
	AddSearchAttributes(ctx context.Context, in *AddSearchAttributesRequest, opts ...grpc.CallOption) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	RemoveSearchAttributes(ctx context.Context, in *RemoveSearchAttributesRequest, opts ...grpc.CallOption) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(ctx context.Context, in *ListSearchAttributesRequest, opts ...grpc.CallOption) (*ListSearchAttributesResponse, error)
}

OperatorServiceClient is the client API for OperatorService service.

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

func NewOperatorServiceClient 

func NewOperatorServiceClient(cc *grpc.ClientConn) OperatorServiceClient

type OperatorServiceServer 

type OperatorServiceServer interface {
	// AddSearchAttributes add custom search attributes.
	//
	// If successful, returns AddSearchAttributesResponse.
	// If fails, returns INTERNAL code with temporal.api.errordetails.v1.SystemWorkflowFailure in Error Details
	AddSearchAttributes(context.Context, *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)
	// RemoveSearchAttributes removes custom search attributes.
	RemoveSearchAttributes(context.Context, *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, error)
	// GetSearchAttributes returns comprehensive information about search attributes.
	ListSearchAttributes(context.Context, *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)
}

OperatorServiceServer is the server API for OperatorService service.

type RemoveSearchAttributesRequest 

type RemoveSearchAttributesRequest struct {
	// Search attribute names to delete.
	SearchAttributes []string `protobuf:"bytes,1,rep,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
}

func (*RemoveSearchAttributesRequest) Descriptor 

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

func (*RemoveSearchAttributesRequest) Equal 

func (this *RemoveSearchAttributesRequest) Equal(that interface{}) bool

func (*RemoveSearchAttributesRequest) GetSearchAttributes 

func (m *RemoveSearchAttributesRequest) GetSearchAttributes() []string

func (*RemoveSearchAttributesRequest) GoString 

func (this *RemoveSearchAttributesRequest) GoString() string

func (*RemoveSearchAttributesRequest) Marshal 

func (m *RemoveSearchAttributesRequest) Marshal() (dAtA []byte, err error)

func (*RemoveSearchAttributesRequest) MarshalTo 

func (m *RemoveSearchAttributesRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSearchAttributesRequest) MarshalToSizedBuffer 

func (m *RemoveSearchAttributesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveSearchAttributesRequest) ProtoMessage 

func (*RemoveSearchAttributesRequest) ProtoMessage()

func (*RemoveSearchAttributesRequest) Reset 

func (m *RemoveSearchAttributesRequest) Reset()

func (*RemoveSearchAttributesRequest) Size 

func (m *RemoveSearchAttributesRequest) Size() (n int)

func (*RemoveSearchAttributesRequest) String 

func (this *RemoveSearchAttributesRequest) String() string

func (*RemoveSearchAttributesRequest) Unmarshal 

func (m *RemoveSearchAttributesRequest) Unmarshal(dAtA []byte) error

func (*RemoveSearchAttributesRequest) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesRequest) XXX_DiscardUnknown()

func (*RemoveSearchAttributesRequest) XXX_Marshal 

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

func (*RemoveSearchAttributesRequest) XXX_Merge 

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

func (*RemoveSearchAttributesRequest) XXX_Size 

func (m *RemoveSearchAttributesRequest) XXX_Size() int

func (*RemoveSearchAttributesRequest) XXX_Unmarshal 

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

type RemoveSearchAttributesResponse 

type RemoveSearchAttributesResponse struct {
}

func (*RemoveSearchAttributesResponse) Descriptor 

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

func (*RemoveSearchAttributesResponse) Equal 

func (this *RemoveSearchAttributesResponse) Equal(that interface{}) bool

func (*RemoveSearchAttributesResponse) GoString 

func (this *RemoveSearchAttributesResponse) GoString() string

func (*RemoveSearchAttributesResponse) Marshal 

func (m *RemoveSearchAttributesResponse) Marshal() (dAtA []byte, err error)

func (*RemoveSearchAttributesResponse) MarshalTo 

func (m *RemoveSearchAttributesResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoveSearchAttributesResponse) MarshalToSizedBuffer 

func (m *RemoveSearchAttributesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveSearchAttributesResponse) ProtoMessage 

func (*RemoveSearchAttributesResponse) ProtoMessage()

func (*RemoveSearchAttributesResponse) Reset 

func (m *RemoveSearchAttributesResponse) Reset()

func (*RemoveSearchAttributesResponse) Size 

func (m *RemoveSearchAttributesResponse) Size() (n int)

func (*RemoveSearchAttributesResponse) String 

func (this *RemoveSearchAttributesResponse) String() string

func (*RemoveSearchAttributesResponse) Unmarshal 

func (m *RemoveSearchAttributesResponse) Unmarshal(dAtA []byte) error

func (*RemoveSearchAttributesResponse) XXX_DiscardUnknown 

func (m *RemoveSearchAttributesResponse) XXX_DiscardUnknown()

func (*RemoveSearchAttributesResponse) XXX_Marshal 

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

func (*RemoveSearchAttributesResponse) XXX_Merge 

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

func (*RemoveSearchAttributesResponse) XXX_Size 

func (m *RemoveSearchAttributesResponse) XXX_Size() int

func (*RemoveSearchAttributesResponse) XXX_Unmarshal 

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

type UnimplementedOperatorServiceServer 

type UnimplementedOperatorServiceServer struct {
}

UnimplementedOperatorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedOperatorServiceServer) AddSearchAttributes 

func (*UnimplementedOperatorServiceServer) AddSearchAttributes(ctx context.Context, req *AddSearchAttributesRequest) (*AddSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) ListSearchAttributes 

func (*UnimplementedOperatorServiceServer) ListSearchAttributes(ctx context.Context, req *ListSearchAttributesRequest) (*ListSearchAttributesResponse, error)

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes 

func (*UnimplementedOperatorServiceServer) RemoveSearchAttributes(ctx context.Context, req *RemoveSearchAttributesRequest) (*RemoveSearchAttributesResponse, 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.