application

Documentation

Index

• Variables
• func RegisterApplicationServiceServer(s grpc.ServiceRegistrar, srv ApplicationServiceServer)
• type ApplicationServiceClient
  • func NewApplicationServiceClient(cc grpc.ClientConnInterface) ApplicationServiceClient
• type ApplicationServiceServer
• type ApplicationService_ListFieldsClient
• type ApplicationService_ListFieldsServer
• type FieldInfo
  • func (*FieldInfo) Descriptor() ([]byte, []int)
  • func (x *FieldInfo) GetApplicationId() string
  • func (x *FieldInfo) GetApplicationName() string
  • func (x *FieldInfo) GetFieldDescription() string
  • func (x *FieldInfo) GetFieldName() string
  • func (x *FieldInfo) GetTypedTicket() *ticket.TypedTicket
  • func (*FieldInfo) ProtoMessage()
  • func (x *FieldInfo) ProtoReflect() protoreflect.Message
  • func (x *FieldInfo) Reset()
  • func (x *FieldInfo) String() string
• type FieldsChangeUpdate
  • func (*FieldsChangeUpdate) Descriptor() ([]byte, []int)
  • func (x *FieldsChangeUpdate) GetCreated() []*FieldInfo
  • func (x *FieldsChangeUpdate) GetRemoved() []*FieldInfo
  • func (x *FieldsChangeUpdate) GetUpdated() []*FieldInfo
  • func (*FieldsChangeUpdate) ProtoMessage()
  • func (x *FieldsChangeUpdate) ProtoReflect() protoreflect.Message
  • func (x *FieldsChangeUpdate) Reset()
  • func (x *FieldsChangeUpdate) String() string
• type ListFieldsRequest
  • func (*ListFieldsRequest) Descriptor() ([]byte, []int)
  • func (*ListFieldsRequest) ProtoMessage()
  • func (x *ListFieldsRequest) ProtoReflect() protoreflect.Message
  • func (x *ListFieldsRequest) Reset()
  • func (x *ListFieldsRequest) String() string
• type UnimplementedApplicationServiceServer
  • func (UnimplementedApplicationServiceServer) ListFields(*ListFieldsRequest, ApplicationService_ListFieldsServer) error
• type UnsafeApplicationServiceServer

Variables

var ApplicationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.deephaven.proto.backplane.grpc.ApplicationService",
	HandlerType: (*ApplicationServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListFields",
			Handler:       _ApplicationService_ListFields_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "deephaven/proto/application.proto",
}

ApplicationService_ServiceDesc is the grpc.ServiceDesc for ApplicationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_deephaven_proto_application_proto protoreflect.FileDescriptor

Functions

func RegisterApplicationServiceServer

func RegisterApplicationServiceServer(s grpc.ServiceRegistrar, srv ApplicationServiceServer)

Types

type ApplicationServiceClient

type ApplicationServiceClient interface {
	//
	// Request the list of the fields exposed via the worker.
	//
	// - The first received message contains all fields that are currently available
	//   on the worker. None of these fields will be RemovedFields.
	// - Subsequent messages modify the existing state. Fields are identified by
	//   their ticket and may be replaced or removed.
	ListFields(ctx context.Context, in *ListFieldsRequest, opts ...grpc.CallOption) (ApplicationService_ListFieldsClient, error)
}

ApplicationServiceClient is the client API for ApplicationService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewApplicationServiceClient

func NewApplicationServiceClient(cc grpc.ClientConnInterface) ApplicationServiceClient

type ApplicationServiceServer

type ApplicationServiceServer interface {
	//
	// Request the list of the fields exposed via the worker.
	//
	// - The first received message contains all fields that are currently available
	//   on the worker. None of these fields will be RemovedFields.
	// - Subsequent messages modify the existing state. Fields are identified by
	//   their ticket and may be replaced or removed.
	ListFields(*ListFieldsRequest, ApplicationService_ListFieldsServer) error
	// contains filtered or unexported methods
}

ApplicationServiceServer is the server API for ApplicationService service. All implementations must embed UnimplementedApplicationServiceServer for forward compatibility

type ApplicationService_ListFieldsClient

type ApplicationService_ListFieldsClient interface {
	Recv() (*FieldsChangeUpdate, error)
	grpc.ClientStream
}

type ApplicationService_ListFieldsServer

type ApplicationService_ListFieldsServer interface {
	Send(*FieldsChangeUpdate) error
	grpc.ServerStream
}

type FieldInfo

type FieldInfo struct {
	TypedTicket      *ticket.TypedTicket `protobuf:"bytes,1,opt,name=typed_ticket,json=typedTicket,proto3" json:"typed_ticket,omitempty"`
	FieldName        string              `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	FieldDescription string              `protobuf:"bytes,3,opt,name=field_description,json=fieldDescription,proto3" json:"field_description,omitempty"`
	ApplicationName  string              `protobuf:"bytes,4,opt,name=application_name,json=applicationName,proto3" json:"application_name,omitempty"` // display-friendly identification
	ApplicationId    string              `protobuf:"bytes,5,opt,name=application_id,json=applicationId,proto3" json:"application_id,omitempty"`       // computer-friendly identification
	// contains filtered or unexported fields
}

A lightweight object describing the exposed field.

func (*FieldInfo) Descriptor

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

Deprecated: Use FieldInfo.ProtoReflect.Descriptor instead.

func (*FieldInfo) GetApplicationId

func (x *FieldInfo) GetApplicationId() string

func (*FieldInfo) GetApplicationName

func (x *FieldInfo) GetApplicationName() string

func (*FieldInfo) GetFieldDescription

func (x *FieldInfo) GetFieldDescription() string

func (*FieldInfo) GetFieldName

func (x *FieldInfo) GetFieldName() string

func (*FieldInfo) GetTypedTicket

func (x *FieldInfo) GetTypedTicket() *ticket.TypedTicket

func (*FieldInfo) ProtoMessage

func (*FieldInfo) ProtoMessage()

func (*FieldInfo) ProtoReflect

func (x *FieldInfo) ProtoReflect() protoreflect.Message

func (*FieldInfo) Reset

func (x *FieldInfo) Reset()

func (*FieldInfo) String

func (x *FieldInfo) String() string

type FieldsChangeUpdate

type FieldsChangeUpdate struct {
	Created []*FieldInfo `protobuf:"bytes,1,rep,name=created,proto3" json:"created,omitempty"`
	Updated []*FieldInfo `protobuf:"bytes,2,rep,name=updated,proto3" json:"updated,omitempty"`
	Removed []*FieldInfo `protobuf:"bytes,3,rep,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

Represents a batch of fields.

func (*FieldsChangeUpdate) Descriptor

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

Deprecated: Use FieldsChangeUpdate.ProtoReflect.Descriptor instead.

func (*FieldsChangeUpdate) GetCreated

func (x *FieldsChangeUpdate) GetCreated() []*FieldInfo

func (*FieldsChangeUpdate) GetRemoved

func (x *FieldsChangeUpdate) GetRemoved() []*FieldInfo

func (*FieldsChangeUpdate) GetUpdated

func (x *FieldsChangeUpdate) GetUpdated() []*FieldInfo

func (*FieldsChangeUpdate) ProtoMessage

func (*FieldsChangeUpdate) ProtoMessage()

func (*FieldsChangeUpdate) ProtoReflect

func (x *FieldsChangeUpdate) ProtoReflect() protoreflect.Message

func (*FieldsChangeUpdate) Reset

func (x *FieldsChangeUpdate) Reset()

func (*FieldsChangeUpdate) String

func (x *FieldsChangeUpdate) String() string

type ListFieldsRequest

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

func (*ListFieldsRequest) Descriptor

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

Deprecated: Use ListFieldsRequest.ProtoReflect.Descriptor instead.

func (*ListFieldsRequest) ProtoMessage

func (*ListFieldsRequest) ProtoMessage()

func (*ListFieldsRequest) ProtoReflect

func (x *ListFieldsRequest) ProtoReflect() protoreflect.Message

func (*ListFieldsRequest) Reset

func (x *ListFieldsRequest) Reset()

func (*ListFieldsRequest) String

func (x *ListFieldsRequest) String() string

type UnimplementedApplicationServiceServer

type UnimplementedApplicationServiceServer struct {
}

UnimplementedApplicationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedApplicationServiceServer) ListFields

func (UnimplementedApplicationServiceServer) ListFields(*ListFieldsRequest, ApplicationService_ListFieldsServer) error

type UnsafeApplicationServiceServer

type UnsafeApplicationServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeApplicationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ApplicationServiceServer will result in compilation errors.