instantv1alpha1

package
v1.9.6 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	InstantDataService_StreamAgentEvents_FullMethodName  = "/services.omnichannel.instant.v1alpha1.InstantDataService/StreamAgentEvents"
	InstantDataService_StreamCallerEvents_FullMethodName = "/services.omnichannel.instant.v1alpha1.InstantDataService/StreamCallerEvents"
)

Variables

View Source 
var File_services_omnichannel_instant_v1alpha1_service_proto protoreflect.FileDescriptor
View Source 
var InstantDataService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.omnichannel.instant.v1alpha1.InstantDataService",
	HandlerType: (*InstantDataServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamAgentEvents",
			Handler:       _InstantDataService_StreamAgentEvents_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamCallerEvents",
			Handler:       _InstantDataService_StreamCallerEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "services/omnichannel/instant/v1alpha1/service.proto",
}

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

Functions

func RegisterInstantDataServiceServer 

func RegisterInstantDataServiceServer(s grpc.ServiceRegistrar, srv InstantDataServiceServer)

Types

type AgentEvent 

type AgentEvent struct {
	OrgId     string                 `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ClientSid int64                  `protobuf:"varint,2,opt,name=client_sid,json=clientSid,proto3" json:"client_sid,omitempty"`
	AgentSid  int64                  `protobuf:"varint,3,opt,name=agent_sid,json=agentSid,proto3" json:"agent_sid,omitempty"`
	UserId    string                 `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	EventTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// A JSON blob representing the Agent's state.
	EventData string `protobuf:"bytes,6,opt,name=event_data,json=eventData,proto3" json:"event_data,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentEvent) Descriptor deprecated 

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

Deprecated: Use AgentEvent.ProtoReflect.Descriptor instead.

func (*AgentEvent) GetAgentSid 

func (x *AgentEvent) GetAgentSid() int64

func (*AgentEvent) GetClientSid 

func (x *AgentEvent) GetClientSid() int64

func (*AgentEvent) GetEventData 

func (x *AgentEvent) GetEventData() string

func (*AgentEvent) GetEventTime 

func (x *AgentEvent) GetEventTime() *timestamppb.Timestamp

func (*AgentEvent) GetOrgId 

func (x *AgentEvent) GetOrgId() string

func (*AgentEvent) GetUserId 

func (x *AgentEvent) GetUserId() string

func (*AgentEvent) ProtoMessage 

func (*AgentEvent) ProtoMessage()

func (*AgentEvent) ProtoReflect 

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

func (*AgentEvent) Reset 

func (x *AgentEvent) Reset()

func (*AgentEvent) String 

func (x *AgentEvent) String() string

type CallerEvent 

type CallerEvent struct {
	OrgId      string                 `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ClientSid  int64                  `protobuf:"varint,2,opt,name=client_sid,json=clientSid,proto3" json:"client_sid,omitempty"`
	CallerSid  int64                  `protobuf:"varint,3,opt,name=caller_sid,json=callerSid,proto3" json:"caller_sid,omitempty"`
	CallerType commons.CallType_Enum  `protobuf:"varint,4,opt,name=caller_type,json=callerType,proto3,enum=api.commons.CallType_Enum" json:"caller_type,omitempty"`
	EventTime  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// A JSON blob resresenting the Caller's state.
	EventData string `protobuf:"bytes,6,opt,name=event_data,json=eventData,proto3" json:"event_data,omitempty"`
	// contains filtered or unexported fields
}

func (*CallerEvent) Descriptor deprecated 

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

Deprecated: Use CallerEvent.ProtoReflect.Descriptor instead.

func (*CallerEvent) GetCallerSid 

func (x *CallerEvent) GetCallerSid() int64

func (*CallerEvent) GetCallerType 

func (x *CallerEvent) GetCallerType() commons.CallType_Enum

func (*CallerEvent) GetClientSid 

func (x *CallerEvent) GetClientSid() int64

func (*CallerEvent) GetEventData 

func (x *CallerEvent) GetEventData() string

func (*CallerEvent) GetEventTime 

func (x *CallerEvent) GetEventTime() *timestamppb.Timestamp

func (*CallerEvent) GetOrgId 

func (x *CallerEvent) GetOrgId() string

func (*CallerEvent) ProtoMessage 

func (*CallerEvent) ProtoMessage()

func (*CallerEvent) ProtoReflect 

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

func (*CallerEvent) Reset 

func (x *CallerEvent) Reset()

func (*CallerEvent) String 

func (x *CallerEvent) String() string

type InstantDataServiceClient 

type InstantDataServiceClient interface {
	StreamAgentEvents(ctx context.Context, in *StreamAgentEventsRequest, opts ...grpc.CallOption) (InstantDataService_StreamAgentEventsClient, error)
	StreamCallerEvents(ctx context.Context, in *StreamCallerEventsRequest, opts ...grpc.CallOption) (InstantDataService_StreamCallerEventsClient, error)
}

InstantDataServiceClient is the client API for InstantDataService 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 NewInstantDataServiceClient 

func NewInstantDataServiceClient(cc grpc.ClientConnInterface) InstantDataServiceClient

type InstantDataServiceServer 

type InstantDataServiceServer interface {
	StreamAgentEvents(*StreamAgentEventsRequest, InstantDataService_StreamAgentEventsServer) error
	StreamCallerEvents(*StreamCallerEventsRequest, InstantDataService_StreamCallerEventsServer) error
	// contains filtered or unexported methods
}

InstantDataServiceServer is the server API for InstantDataService service. All implementations must embed UnimplementedInstantDataServiceServer for forward compatibility.

type InstantDataService_StreamAgentEventsClient 

type InstantDataService_StreamAgentEventsClient interface {
	Recv() (*StreamAgentEventsResponse, error)
	grpc.ClientStream
}

type InstantDataService_StreamAgentEventsServer 

type InstantDataService_StreamAgentEventsServer interface {
	Send(*StreamAgentEventsResponse) error
	grpc.ServerStream
}

type InstantDataService_StreamCallerEventsClient 

type InstantDataService_StreamCallerEventsClient interface {
	Recv() (*StreamCallerEventsResponse, error)
	grpc.ClientStream
}

type InstantDataService_StreamCallerEventsServer 

type InstantDataService_StreamCallerEventsServer interface {
	Send(*StreamCallerEventsResponse) error
	grpc.ServerStream
}

type StreamAgentEventsRequest 

type StreamAgentEventsRequest struct {

	// The org for which to stream events.
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamAgentEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamAgentEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamAgentEventsRequest) GetOrgId 

func (x *StreamAgentEventsRequest) GetOrgId() string

func (*StreamAgentEventsRequest) ProtoMessage 

func (*StreamAgentEventsRequest) ProtoMessage()

func (*StreamAgentEventsRequest) ProtoReflect 

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

func (*StreamAgentEventsRequest) Reset 

func (x *StreamAgentEventsRequest) Reset()

func (*StreamAgentEventsRequest) String 

func (x *StreamAgentEventsRequest) String() string

type StreamAgentEventsResponse 

type StreamAgentEventsResponse struct {

	// One or more agent events. The initial response will contain a full
	// snapshot of every agent's state. Each subsequent response will contain a
	// single event.
	Event []*AgentEvent `protobuf:"bytes,1,rep,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamAgentEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamAgentEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamAgentEventsResponse) GetEvent 

func (x *StreamAgentEventsResponse) GetEvent() []*AgentEvent

func (*StreamAgentEventsResponse) ProtoMessage 

func (*StreamAgentEventsResponse) ProtoMessage()

func (*StreamAgentEventsResponse) ProtoReflect 

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

func (*StreamAgentEventsResponse) Reset 

func (x *StreamAgentEventsResponse) Reset()

func (*StreamAgentEventsResponse) String 

func (x *StreamAgentEventsResponse) String() string

type StreamCallerEventsRequest 

type StreamCallerEventsRequest struct {

	// The org for which to stream events.
	OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallerEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamCallerEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamCallerEventsRequest) GetOrgId 

func (x *StreamCallerEventsRequest) GetOrgId() string

func (*StreamCallerEventsRequest) ProtoMessage 

func (*StreamCallerEventsRequest) ProtoMessage()

func (*StreamCallerEventsRequest) ProtoReflect 

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

func (*StreamCallerEventsRequest) Reset 

func (x *StreamCallerEventsRequest) Reset()

func (*StreamCallerEventsRequest) String 

func (x *StreamCallerEventsRequest) String() string

type StreamCallerEventsResponse 

type StreamCallerEventsResponse struct {

	// One or more caller events. The initial response will contain a full
	// snapshot of every caller's state. Each subsequent response will contain a
	// single event.
	Event []*CallerEvent `protobuf:"bytes,1,rep,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamCallerEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamCallerEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamCallerEventsResponse) GetEvent 

func (x *StreamCallerEventsResponse) GetEvent() []*CallerEvent

func (*StreamCallerEventsResponse) ProtoMessage 

func (*StreamCallerEventsResponse) ProtoMessage()

func (*StreamCallerEventsResponse) ProtoReflect 

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

func (*StreamCallerEventsResponse) Reset 

func (x *StreamCallerEventsResponse) Reset()

func (*StreamCallerEventsResponse) String 

func (x *StreamCallerEventsResponse) String() string

type UnimplementedInstantDataServiceServer 

type UnimplementedInstantDataServiceServer struct{}

UnimplementedInstantDataServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedInstantDataServiceServer) StreamAgentEvents 

func (UnimplementedInstantDataServiceServer) StreamAgentEvents(*StreamAgentEventsRequest, InstantDataService_StreamAgentEventsServer) error

func (UnimplementedInstantDataServiceServer) StreamCallerEvents 

func (UnimplementedInstantDataServiceServer) StreamCallerEvents(*StreamCallerEventsRequest, InstantDataService_StreamCallerEventsServer) error

type UnsafeInstantDataServiceServer 

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

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

Source Files

View all Source files

Directories

Path Synopsis

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.