service

Documentation

Overview

Package service is a generated protocol buffer package.

It is generated from these files:

github.com/appcelerator/amp/api/rpc/service/service.proto

It has these top-level messages:

TasksRequest
Task
TasksReply

Package service is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

• func RegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
• func RegisterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
• func RegisterServiceServer(s *grpc.Server, srv ServiceServer)
• type Server
  • func (s *Server) Tasks(ctx context.Context, in *TasksRequest) (*TasksReply, error)
• type ServiceClient
  • func NewServiceClient(cc *grpc.ClientConn) ServiceClient
• type ServiceServer
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (m *Task) GetDesiredState() string
  • func (m *Task) GetId() string
  • func (m *Task) GetImage() string
  • func (m *Task) GetNodeId() string
  • func (m *Task) GetState() string
  • func (*Task) ProtoMessage()
  • func (m *Task) Reset()
  • func (m *Task) String() string
• type TasksReply
  • func (*TasksReply) Descriptor() ([]byte, []int)
  • func (m *TasksReply) GetTasks() []*Task
  • func (*TasksReply) ProtoMessage()
  • func (m *TasksReply) Reset()
  • func (m *TasksReply) String() string
• type TasksRequest
  • func (*TasksRequest) Descriptor() ([]byte, []int)
  • func (m *TasksRequest) GetServiceId() string
  • func (*TasksRequest) ProtoMessage()
  • func (m *TasksRequest) Reset()
  • func (m *TasksRequest) String() string

Functions

func RegisterServiceHandler

func RegisterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterServiceHandler registers the http handlers for service Service to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterServiceHandlerFromEndpoint

func RegisterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterServiceHandlerFromEndpoint is same as RegisterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterServiceServer

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type Server

type Server struct {
	Docker *docker.Docker
}

Server is used to implement log.LogServer

func (*Server) Tasks

func (s *Server) Tasks(ctx context.Context, in *TasksRequest) (*TasksReply, error)

Tasks implements service.Containers

type ServiceClient

type ServiceClient interface {
	Tasks(ctx context.Context, in *TasksRequest, opts ...grpc.CallOption) (*TasksReply, error)
}

func NewServiceClient

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceServer

type ServiceServer interface {
	Tasks(context.Context, *TasksRequest) (*TasksReply, error)
}

type Task

type Task struct {
	Id           string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Image        string `protobuf:"bytes,2,opt,name=image" json:"image,omitempty"`
	State        string `protobuf:"bytes,3,opt,name=state" json:"state,omitempty"`
	DesiredState string `protobuf:"bytes,4,opt,name=desired_state,json=desiredState" json:"desired_state,omitempty"`
	NodeId       string `protobuf:"bytes,5,opt,name=node_id,json=nodeId" json:"node_id,omitempty"`
}

func (*Task) Descriptor

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

func (*Task) GetDesiredState

func (m *Task) GetDesiredState() string

func (*Task) GetId

func (m *Task) GetId() string

func (*Task) GetImage

func (m *Task) GetImage() string

func (*Task) GetNodeId

func (m *Task) GetNodeId() string

func (*Task) GetState

func (m *Task) GetState() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

type TasksReply

type TasksReply struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*TasksReply) Descriptor

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

func (*TasksReply) GetTasks

func (m *TasksReply) GetTasks() []*Task

func (*TasksReply) ProtoMessage

func (*TasksReply) ProtoMessage()

func (*TasksReply) Reset

func (m *TasksReply) Reset()

func (*TasksReply) String

func (m *TasksReply) String() string

type TasksRequest

type TasksRequest struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
}

func (*TasksRequest) Descriptor

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

func (*TasksRequest) GetServiceId

func (m *TasksRequest) GetServiceId() string

func (*TasksRequest) ProtoMessage

func (*TasksRequest) ProtoMessage()

func (*TasksRequest) Reset

func (m *TasksRequest) Reset()

func (*TasksRequest) String

func (m *TasksRequest) String() string